public class PagedMessageImpl extends Object implements PagedMessage
Constructor and Description |
---|
PagedMessageImpl() |
PagedMessageImpl(ServerMessage message,
long[] queueIDs) |
PagedMessageImpl(ServerMessage message,
long[] queueIDs,
long transactionID) |
Modifier and Type | Method and Description |
---|---|
void |
decode(ActiveMQBuffer buffer) |
void |
encode(ActiveMQBuffer buffer) |
int |
getEncodeSize() |
ServerMessage |
getMessage() |
long[] |
getQueueIDs()
The queues that were routed during paging
|
long |
getTransactionID() |
void |
initMessage(StorageManager storage) |
String |
toString() |
public PagedMessageImpl(ServerMessage message, long[] queueIDs, long transactionID)
public PagedMessageImpl(ServerMessage message, long[] queueIDs)
public PagedMessageImpl()
public ServerMessage 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 int getEncodeSize()
getEncodeSize
in interface EncodingSupport
Copyright © 2017 JBoss by Red Hat. All rights reserved.