org.apache.qpid.client.message
Class MessageFactoryRegistry
java.lang.Object
org.apache.qpid.client.message.MessageFactoryRegistry
public class MessageFactoryRegistry
- extends Object
Field Summary |
protected org.slf4j.Logger |
_logger
This class logger |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_logger
protected final org.slf4j.Logger _logger
- This class logger
MessageFactoryRegistry
public MessageFactoryRegistry()
newDefaultRegistry
public static MessageFactoryRegistry newDefaultRegistry()
- Construct a new registry with the default message factories registered
- Returns:
- a message factory registry
registerFactory
public void registerFactory(String mimeType,
MessageFactory mf)
deregisterFactory
public MessageFactory deregisterFactory(String mimeType)
createMessage
public AbstractJMSMessage createMessage(long deliveryTag,
boolean redelivered,
org.apache.qpid.framing.AMQShortString exchange,
org.apache.qpid.framing.AMQShortString routingKey,
org.apache.qpid.framing.ContentHeaderBody contentHeader,
List bodies)
throws org.apache.qpid.AMQException,
JMSException
- Create a message. This looks up the MIME type from the content header and instantiates the appropriate
concrete message type.
- Parameters:
deliveryTag
- the AMQ message idredelivered
- true if redeliveredcontentHeader
- the content header that was receivedbodies
- a list of ContentBody instances @return the message.
- Throws:
org.apache.qpid.AMQException
JMSException
createMessage
public AbstractJMSMessage createMessage(org.apache.qpid.transport.MessageTransfer transfer)
throws org.apache.qpid.AMQException,
JMSException
- Throws:
org.apache.qpid.AMQException
JMSException
createMessage
public AbstractJMSMessage createMessage(AMQMessageDelegateFactory delegateFactory,
String mimeType)
throws org.apache.qpid.AMQException,
JMSException
- Throws:
org.apache.qpid.AMQException
JMSException
Licensed to the Apache Software Foundation