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) |
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, 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 forceDelivery(long sequence)
void setTransferring(boolean transferring)
boolean isBrowseOnly()
long getCreationTime()
String getSessionID()
Copyright © 2018 JBoss by Red Hat. All rights reserved.