org.apache.qpid.qmf
Class QMFMessage
java.lang.Object
org.apache.qpid.qmf.QMFMessage
- All Implemented Interfaces:
- AMQMessageHeader, EnqueableMessage, InboundMessage, MessageContentSource, ServerMessage, Filterable
public class QMFMessage
- extends Object
- implements ServerMessage, InboundMessage, AMQMessageHeader
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
QMFMessage
public QMFMessage(String routingKey,
QMFCommand command)
QMFMessage
public QMFMessage(String routingKey,
QMFCommand[] commands)
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