org.apache.qpid.server.message
Class MessageTransferMessage

java.lang.Object
  extended by org.apache.qpid.server.message.MessageTransferMessage
All Implemented Interfaces:
EnqueableMessage, InboundMessage, MessageContentSource, ServerMessage, Filterable

public class MessageTransferMessage
extends Object
implements InboundMessage, ServerMessage


Constructor Summary
MessageTransferMessage(StoredMessage<MessageMetaData_0_10> storeMessage, WeakReference<org.apache.qpid.transport.Session> sessionRef)
           
 
Method Summary
 long getArrivalTime()
           
 ByteBuffer getBody()
           
 int getContent(ByteBuffer buf, int offset)
           
 long getExpiration()
           
 org.apache.qpid.transport.Header getHeader()
           
 AMQMessageHeader getMessageHeader()
           
 Long getMessageNumber()
           
 String getRoutingKey()
           
 org.apache.qpid.transport.Session getSession()
           
 SessionConfig getSessionConfig()
           
 long getSize()
           
 boolean isImmediate()
           
 boolean isPersistent()
           
 boolean isRedelivered()
           
 MessageReference newReference()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageTransferMessage

public MessageTransferMessage(StoredMessage<MessageMetaData_0_10> storeMessage,
                              WeakReference<org.apache.qpid.transport.Session> sessionRef)
Method Detail

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