public interface MessageReference
Modifier and Type | Method and Description |
---|---|
void |
acknowledge() |
void |
acknowledge(Transaction tx) |
void |
acknowledge(Transaction tx,
AckReason reason) |
MessageReference |
copy(Queue queue) |
void |
decrementDeliveryCount() |
Long |
getConsumerId() |
int |
getDeliveryCount() |
ServerMessage |
getMessage() |
int |
getMessageMemoryEstimate()
We define this method aggregation here because on paging we need to hold the original estimate,
so we need to perform some extra steps on paging.
|
int |
getPersistedCount() |
Object |
getProtocolData()
To be used on holding protocol specific data during the delivery.
|
Queue |
getQueue() |
long |
getScheduledDeliveryTime() |
void |
handled() |
void |
incrementDeliveryCount() |
boolean |
isAlreadyAcked() |
boolean |
isPaged() |
void |
setAlreadyAcked() |
void |
setConsumerId(Long consumerID) |
void |
setDeliveryCount(int deliveryCount) |
void |
setPersistedCount(int deliveryCount) |
void |
setProtocolData(Object data)
To be used on holding protocol specific data during the delivery.
|
void |
setScheduledDeliveryTime(long scheduledDeliveryTime) |
boolean isPaged()
ServerMessage getMessage()
int getMessageMemoryEstimate()
Object getProtocolData()
void setProtocolData(Object data)
MessageReference copy(Queue queue)
long getScheduledDeliveryTime()
void setScheduledDeliveryTime(long scheduledDeliveryTime)
int getDeliveryCount()
void setDeliveryCount(int deliveryCount)
void setPersistedCount(int deliveryCount)
int getPersistedCount()
void incrementDeliveryCount()
void decrementDeliveryCount()
Queue getQueue()
void acknowledge(Transaction tx) throws Exception
Exception
void acknowledge(Transaction tx, AckReason reason) throws Exception
Exception
void setConsumerId(Long consumerID)
Long getConsumerId()
void handled()
void setAlreadyAcked()
boolean isAlreadyAcked()
Copyright © 2017 JBoss by Red Hat. All rights reserved.