From 0387b1a8427673f42166df5651bc504d38f365ce Mon Sep 17 00:00:00 2001
From: Francesco Nigro <nigro.fra@gmail.com>
Date: Mon, 22 Jan 2018 19:57:29 +0100
Subject: [PATCH] ARTEMIS-1616 OpenWire improvements

Refactored OpenWireMessageConverter::inbound into a private static method
---
 .../protocol/openwire/OpenWireMessageConverter.java    | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireMessageConverter.java b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireMessageConverter.java
index 3dc4a4ea7d..19dc80209a 100644
--- a/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireMessageConverter.java
+++ b/artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireMessageConverter.java
@@ -120,10 +120,14 @@ public class OpenWireMessageConverter implements MessageConverter<OpenwireMessag
       return null;
    }
 
-   //   @Override
-   public org.apache.activemq.artemis.api.core.Message inbound(Object message, CoreMessageObjectPools coreMessageObjectPools) throws Exception {
+   public org.apache.activemq.artemis.api.core.Message inbound(Message message, CoreMessageObjectPools coreMessageObjectPools) throws Exception {
+      return inbound(message, marshaller, coreMessageObjectPools);
+   }
+
+   private static org.apache.activemq.artemis.api.core.Message inbound(final Message messageSend,
+                                                                       final WireFormat marshaller,
+                                                                       final CoreMessageObjectPools coreMessageObjectPools) throws Exception {
 
-      final Message messageSend = (Message) message;
       final CoreMessage coreMessage = new CoreMessage(-1, messageSend.getSize(), coreMessageObjectPools);
 
       final String type = messageSend.getType();