public interface ServerConsumer extends Consumer
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
List<MessageReference> |
cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
void |
close(boolean failed) |
void |
forceDelivery(long sequence) |
Object |
getConnectionID() |
long |
getCreationTime() |
long |
getID() |
Queue |
getQueue() |
String |
getSessionID() |
void |
individualAcknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
void |
individualCancel(long messageID,
boolean failed) |
boolean |
isBrowseOnly() |
void |
receiveCredits(int credits) |
void |
removeItself()
This method is just to remove itself from Queues.
|
MessageReference |
removeReferenceByID(long messageID) |
void |
setStarted(boolean started) |
void |
setTransferring(boolean transferring) |
debug, disconnect, getDeliveringMessages, getFilter, handle, proceedDeliver, toManagementString
long getID()
Object getConnectionID()
void removeItself() throws Exception
Exception
List<MessageReference> cancelRefs(boolean failed, boolean lastConsumedAsDelivered, Transaction tx) throws Exception
Exception
void setStarted(boolean started)
Queue getQueue()
MessageReference removeReferenceByID(long messageID) throws Exception
Exception
void acknowledge(boolean autoCommitAcks, Transaction tx, long messageID) throws Exception
Exception
void individualAcknowledge(boolean autoCommitAcks, Transaction tx, long messageID) throws Exception
Exception
void individualCancel(long messageID, boolean failed) throws Exception
Exception
void forceDelivery(long sequence)
void setTransferring(boolean transferring)
boolean isBrowseOnly()
long getCreationTime()
String getSessionID()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.