public class MessageFactoryRegistry extends Object
Constructor and Description |
---|
MessageFactoryRegistry(AMQSession<?,?> session) |
Modifier and Type | Method and Description |
---|---|
AbstractJMSMessage |
createMessage(long deliveryTag,
boolean redelivered,
String exchange,
String routingKey,
ContentHeaderBody contentHeader,
List bodies,
AMQSession_0_8.DestinationCache<AMQQueue> queueDestinationCache,
AMQSession_0_8.DestinationCache<AMQTopic> topicDestinationCache,
int addressType)
Create a message.
|
AbstractJMSMessage |
createMessage(MessageTransfer transfer) |
AMQSession<?,?> |
getSession() |
static MessageFactoryRegistry |
newDefaultRegistry(AMQSession<?,?> session)
Construct a new registry with the default message factories registered
|
void |
registerFactory(String mimeType,
AbstractJMSMessageFactory mf) |
public MessageFactoryRegistry(AMQSession<?,?> session)
public static MessageFactoryRegistry newDefaultRegistry(AMQSession<?,?> session)
session
- public void registerFactory(String mimeType, AbstractJMSMessageFactory mf)
public AbstractJMSMessage createMessage(long deliveryTag, boolean redelivered, String exchange, String routingKey, ContentHeaderBody contentHeader, List bodies, AMQSession_0_8.DestinationCache<AMQQueue> queueDestinationCache, AMQSession_0_8.DestinationCache<AMQTopic> topicDestinationCache, int addressType) throws QpidException, javax.jms.JMSException
deliveryTag
- the AMQ message idredelivered
- true if redeliveredcontentHeader
- the content header that was receivedbodies
- a list of ContentBody instances @return the message.queueDestinationCache
- topicDestinationCache
- addressType
- javax.jms.JMSException
QpidException
public AbstractJMSMessage createMessage(MessageTransfer transfer) throws QpidException, javax.jms.JMSException
QpidException
javax.jms.JMSException
public AMQSession<?,?> getSession()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.