Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-03-04 08:19:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-1616 OpenWire improvements

Browse Source 
Refactored OpenWireMessageConverter::inbound into a private static method
This commit is contained in:
Francesco Nigro 2018-01-22 19:57:29 +01:00 committed by Clebert Suconic
parent c6b6dd95d1
commit 0387b1a842
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireMessageConverter.java
View File

@ -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();