|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.server.message.AMQMessage
public class AMQMessage
A deliverable message.
Field Summary | |
---|---|
(package private) WeakReference<AMQChannel> |
_channelRef
|
Constructor Summary | |
---|---|
AMQMessage(StoredMessage<MessageMetaData> handle)
|
|
AMQMessage(StoredMessage<MessageMetaData> handle,
WeakReference<AMQChannel> channelRef)
|
Method Summary | |
---|---|
String |
debugIdentity()
|
void |
decrementReference()
Threadsafe. |
boolean |
expired(AMQQueue queue)
Checks to see if the message has expired. |
long |
getArrivalTime()
|
int |
getContent(ByteBuffer buf,
int offset)
|
org.apache.qpid.framing.ContentHeaderBody |
getContentHeaderBody()
|
boolean |
getDeliveredToConsumer()
Called selectors to determin if the message has already been sent |
long |
getExpiration()
|
AMQMessageHeader |
getMessageHeader()
|
Long |
getMessageId()
|
MessageMetaData |
getMessageMetaData()
|
Long |
getMessageNumber()
|
org.apache.qpid.framing.abstraction.MessagePublishInfo |
getMessagePublishInfo()
|
Object |
getPublisherIdentifier()
|
String |
getRoutingKey()
|
SessionConfig |
getSessionConfig()
|
long |
getSize()
|
StoredMessage<MessageMetaData> |
getStoredMessage()
|
boolean |
immediateAndNotDelivered()
Called to enforce the 'immediate' flag. |
boolean |
incrementReference()
|
boolean |
incrementReference(int count)
|
boolean |
isImmediate()
|
boolean |
isPersistent()
|
boolean |
isReferenced()
|
MessageReference |
newReference()
|
void |
setClientIdentifier(Object sessionIdentifier)
|
void |
setDeliveredToConsumer()
Called when this message is delivered to a consumer. |
void |
setExpiration(long expiration)
|
AMQMessage |
takeReference()
Creates a long-lived reference to this message, and increments the count of such references, as an atomic operation. |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
WeakReference<AMQChannel> _channelRef
Constructor Detail |
---|
public AMQMessage(StoredMessage<MessageMetaData> handle)
public AMQMessage(StoredMessage<MessageMetaData> handle, WeakReference<AMQChannel> channelRef)
Method Detail |
---|
public String debugIdentity()
public void setExpiration(long expiration)
public boolean isReferenced()
public MessageMetaData getMessageMetaData()
public org.apache.qpid.framing.ContentHeaderBody getContentHeaderBody() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public Long getMessageId()
public AMQMessage takeReference()
public boolean incrementReference()
public boolean incrementReference(int count)
public void decrementReference()
MessageCleanupException
- when an attempt was made to remove the message from the message store and that
failedpublic boolean getDeliveredToConsumer()
public String getRoutingKey()
getRoutingKey
in interface ServerMessage
public AMQMessageHeader getMessageHeader()
getMessageHeader
in interface ServerMessage
public boolean isPersistent()
isPersistent
in interface EnqueableMessage
isPersistent
in interface ServerMessage
public boolean immediateAndNotDelivered()
public org.apache.qpid.framing.abstraction.MessagePublishInfo getMessagePublishInfo() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
public long getArrivalTime()
getArrivalTime
in interface ServerMessage
public boolean expired(AMQQueue queue) throws org.apache.qpid.AMQException
queue
- The queue to check the expiration against. (Currently not used)
org.apache.qpid.AMQException
public void setDeliveredToConsumer()
public long getSize()
getSize
in interface MessageContentSource
getSize
in interface ServerMessage
public boolean isImmediate()
isImmediate
in interface ServerMessage
public long getExpiration()
getExpiration
in interface ServerMessage
public MessageReference newReference()
newReference
in interface ServerMessage
public Long getMessageNumber()
getMessageNumber
in interface EnqueableMessage
getMessageNumber
in interface ServerMessage
public Object getPublisherIdentifier()
public void setClientIdentifier(Object sessionIdentifier)
public String toString()
toString
in class Object
public int getContent(ByteBuffer buf, int offset)
getContent
in interface MessageContentSource
getContent
in interface ServerMessage
public StoredMessage<MessageMetaData> getStoredMessage()
public SessionConfig getSessionConfig()
getSessionConfig
in interface ServerMessage
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |