org.apache.qpid.qmf
Class QMFMessage

java.lang.Object
  extended by org.apache.qpid.qmf.QMFMessage
All Implemented Interfaces:
AMQMessageHeader, EnqueableMessage, InboundMessage, MessageContentSource, ServerMessage, Filterable

public class QMFMessage
extends Object
implements ServerMessage, InboundMessage, AMQMessageHeader


Constructor Summary
QMFMessage(String routingKey, QMFCommand command)
           
QMFMessage(String routingKey, QMFCommand[] commands)
           
 
Method Summary
 boolean containsHeader(String name)
           
 boolean containsHeaders(Set<String> names)
           
 long getArrivalTime()
           
 int getContent(ByteBuffer buf, int offset)
           
 String getCorrelationId()
           
 String getEncoding()
           
 long getExpiration()
           
 Object getHeader(String name)
           
 AMQMessageHeader getMessageHeader()
           
 String getMessageId()
           
 Long getMessageNumber()
           
 String getMimeType()
           
 byte getPriority()
           
 String getReplyTo()
           
 String getReplyToExchange()
           
 String getReplyToRoutingKey()
           
 String getRoutingKey()
           
 SessionConfig getSessionConfig()
           
 long getSize()
           
 long getTimestamp()
           
 String getType()
           
 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

QMFMessage

public QMFMessage(String routingKey,
                  QMFCommand command)

QMFMessage

public QMFMessage(String routingKey,
                  QMFCommand[] commands)
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

getCorrelationId

public String getCorrelationId()
Specified by:
getCorrelationId in interface AMQMessageHeader

getExpiration

public long getExpiration()
Specified by:
getExpiration in interface AMQMessageHeader
Specified by:
getExpiration in interface ServerMessage

getMessageId

public String getMessageId()
Specified by:
getMessageId in interface AMQMessageHeader

getMimeType

public String getMimeType()
Specified by:
getMimeType in interface AMQMessageHeader

getEncoding

public String getEncoding()
Specified by:
getEncoding in interface AMQMessageHeader

getPriority

public byte getPriority()
Specified by:
getPriority in interface AMQMessageHeader

getTimestamp

public long getTimestamp()
Specified by:
getTimestamp in interface AMQMessageHeader

getType

public String getType()
Specified by:
getType in interface AMQMessageHeader

getReplyTo

public String getReplyTo()
Specified by:
getReplyTo in interface AMQMessageHeader

getReplyToExchange

public String getReplyToExchange()
Specified by:
getReplyToExchange in interface AMQMessageHeader

getReplyToRoutingKey

public String getReplyToRoutingKey()
Specified by:
getReplyToRoutingKey in interface AMQMessageHeader

getHeader

public Object getHeader(String name)
Specified by:
getHeader in interface AMQMessageHeader

containsHeaders

public boolean containsHeaders(Set<String> names)
Specified by:
containsHeaders in interface AMQMessageHeader

containsHeader

public boolean containsHeader(String name)
Specified by:
containsHeader in interface AMQMessageHeader

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

getSessionConfig

public SessionConfig getSessionConfig()
Specified by:
getSessionConfig in interface ServerMessage


Licensed to the Apache Software Foundation