public class ProtonMessageConverter extends Object implements MessageConverter
Constructor and Description |
---|
ProtonMessageConverter(IDGenerator idGenerator) |
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) |
public ProtonMessageConverter(IDGenerator idGenerator)
public ServerMessage inbound(Object messageSource) throws Exception
inbound
in interface MessageConverter
Exception
public ServerJMSMessage inboundJMSType(EncodedMessage messageSource) throws Exception
messageSource
- Exception
- https://issues.jboss.org/browse/ENTMQ-1560public Object outbound(ServerMessage messageOutbound, int deliveryCount) throws Exception
outbound
in interface MessageConverter
Exception
Copyright © 2016 The Apache Software Foundation. All rights reserved.