org.apache.qpid.server.message
Class MessageTransferMessage
java.lang.Object
org.apache.qpid.server.message.MessageTransferMessage
- All Implemented Interfaces:
- EnqueableMessage, InboundMessage, MessageContentSource, ServerMessage, Filterable
public class MessageTransferMessage
- extends Object
- implements InboundMessage, ServerMessage
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageTransferMessage
public MessageTransferMessage(StoredMessage<MessageMetaData_0_10> storeMessage,
WeakReference<org.apache.qpid.transport.Session> sessionRef)
getRoutingKey
public String getRoutingKey()
- Specified by:
getRoutingKey
in interface InboundMessage
- Specified by:
getRoutingKey
in interface ServerMessage
getMessageHeader
public AMQMessageHeader getMessageHeader()
- Specified by:
getMessageHeader
in interface InboundMessage
- Specified by:
getMessageHeader
in interface ServerMessage
- Specified by:
getMessageHeader
in interface Filterable
isPersistent
public boolean isPersistent()
- Specified by:
isPersistent
in interface EnqueableMessage
- Specified by:
isPersistent
in interface InboundMessage
- Specified by:
isPersistent
in interface ServerMessage
- Specified by:
isPersistent
in interface Filterable
isRedelivered
public boolean isRedelivered()
- Specified by:
isRedelivered
in interface InboundMessage
- Specified by:
isRedelivered
in interface Filterable
getSize
public long getSize()
- Specified by:
getSize
in interface InboundMessage
- Specified by:
getSize
in interface MessageContentSource
- Specified by:
getSize
in interface ServerMessage
isImmediate
public boolean isImmediate()
- Specified by:
isImmediate
in interface ServerMessage
getExpiration
public long getExpiration()
- Specified by:
getExpiration
in interface ServerMessage
newReference
public MessageReference newReference()
- Specified by:
newReference
in interface ServerMessage
getMessageNumber
public Long getMessageNumber()
- Specified by:
getMessageNumber
in interface EnqueableMessage
- Specified by:
getMessageNumber
in interface ServerMessage
getArrivalTime
public long getArrivalTime()
- Specified by:
getArrivalTime
in interface ServerMessage
getContent
public int getContent(ByteBuffer buf,
int offset)
- Specified by:
getContent
in interface MessageContentSource
- Specified by:
getContent
in interface ServerMessage
getHeader
public org.apache.qpid.transport.Header getHeader()
getBody
public ByteBuffer getBody()
getSession
public org.apache.qpid.transport.Session getSession()
getSessionConfig
public SessionConfig getSessionConfig()
- Specified by:
getSessionConfig
in interface ServerMessage
Licensed to the Apache Software Foundation