public class PagedMessageImpl extends Object implements PagedMessage
Constructor and Description |
---|
PagedMessageImpl(Message message,
long[] queueIDs) |
PagedMessageImpl(Message message,
long[] queueIDs,
long transactionID) |
PagedMessageImpl(StorageManager storageManager) |
Modifier and Type | Method and Description |
---|---|
void |
decode(ActiveMQBuffer buffer) |
void |
encode(ActiveMQBuffer buffer) |
int |
getEncodeSize() |
Message |
getMessage() |
long |
getPersistentSize()
This is the size of the message when persisted on disk and is used for metrics tracking
If a normal message it will be the encoded message size
If a large message it will be encoded message size + large message body size
|
long[] |
getQueueIDs()
The queues that were routed during paging
|
long |
getTransactionID() |
void |
initMessage(StorageManager storage) |
boolean |
isLargeMessage() |
String |
toString() |
public PagedMessageImpl(Message message, long[] queueIDs, long transactionID)
public PagedMessageImpl(Message message, long[] queueIDs)
public PagedMessageImpl(StorageManager storageManager)
public Message getMessage()
getMessage
in interface PagedMessage
public void initMessage(StorageManager storage)
initMessage
in interface PagedMessage
public long getTransactionID()
getTransactionID
in interface PagedMessage
public long[] getQueueIDs()
PagedMessage
getQueueIDs
in interface PagedMessage
public void decode(ActiveMQBuffer buffer)
decode
in interface EncodingSupport
public void encode(ActiveMQBuffer buffer)
encode
in interface EncodingSupport
public boolean isLargeMessage()
public int getEncodeSize()
getEncodeSize
in interface EncodingSupport
public long getPersistentSize() throws ActiveMQException
PagedMessage
getPersistentSize
in interface PagedMessage
ActiveMQException
Copyright © 2019 JBoss by Red Hat. All rights reserved.