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) |
MessageReference |
removeReferenceByID(long messageID) |
void |
setStarted(boolean started) |
void |
setTransferring(boolean transferring) |
long getID()
Object getConnectionID()
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 © 2012 JBoss by Red Hat. All Rights Reserved.