public class PagedMessageImpl extends Object implements PagedMessage
Constructor and Description |
---|
PagedMessageImpl(int storedSize,
StorageManager storageManager) |
PagedMessageImpl(Message message,
long[] queueIDs) |
PagedMessageImpl(Message message,
long[] queueIDs,
long transactionID) |
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
|
int |
getStoredSize()
This returns how much the PagedMessage used, or it's going to use
from storage.
|
long |
getTransactionID() |
void |
initMessage(StorageManager storage) |
static boolean |
isLargeMessage(ActiveMQBuffer buffer)
This method won't move the
ActiveMQBuffer.readerIndex() of buffer . |
String |
toString() |
public PagedMessageImpl(Message message, long[] queueIDs, long transactionID)
public PagedMessageImpl(Message message, long[] queueIDs)
public PagedMessageImpl(int storedSize, StorageManager storageManager)
public int getStoredSize()
PagedMessage
getStoredSize
in interface PagedMessage
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 static boolean isLargeMessage(ActiveMQBuffer buffer)
ActiveMQBuffer.readerIndex()
of buffer
.public void decode(ActiveMQBuffer buffer)
decode
in interface EncodingSupport
public void encode(ActiveMQBuffer buffer)
encode
in interface EncodingSupport
public int getEncodeSize()
getEncodeSize
in interface EncodingSupport
public long getPersistentSize() throws ActiveMQException
PagedMessage
getPersistentSize
in interface PagedMessage
ActiveMQException
Copyright © 2021 JBoss by Red Hat. All rights reserved.