org.apache.activemq.artemis.core.protocol.proton.converter

Class ProtonMessageConverter

java.lang.Object

org.apache.activemq.artemis.core.protocol.proton.converter.ProtonMessageConverter

All Implemented Interfaces:

MessageConverter

public class ProtonMessageConverter
extends Object
implements MessageConverter

Constructor Summary

Constructors

Constructor and Description
ProtonMessageConverter(IDGenerator idGenerator)

Method Summary

Modifier and Type	Method and Description
ServerMessage	inbound(Object messageSource)
ServerJMSMessage	inboundJMSType(EncodedMessage messageSource) Just create the JMS Part of the inbound (for testing)
Object	outbound(ServerMessage messageOutbound, int deliveryCount)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProtonMessageConverter

public ProtonMessageConverter(IDGenerator idGenerator)

Method Detail

inbound

public ServerMessage inbound(Object messageSource)
                      throws Exception

Specified by:

inbound in interface MessageConverter

Throws:

Exception

inboundJMSType

public ServerJMSMessage inboundJMSType(EncodedMessage messageSource)
                                throws Exception

Just create the JMS Part of the inbound (for testing)

Parameters:

messageSource -

Returns:

Throws:

Exception - https://issues.jboss.org/browse/ENTMQ-1560

outbound

public Object outbound(ServerMessage messageOutbound,
                       int deliveryCount)
                throws Exception

Specified by:

outbound in interface MessageConverter

Throws:

Exception