public interface ServerConsumer extends Consumer, ConsumerInfo
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(Transaction tx,
long messageID) |
boolean |
allowReferenceCallback()
the current queue settings will allow use of the Reference Execution and callback.
|
void |
backToDelivering(MessageReference reference)
Some protocols may choose to send the message back to delivering instead of redeliver.
|
List<MessageReference> |
cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
void |
close(boolean failed) |
void |
fireSlowConsumer() |
void |
forceDelivery(long sequence) |
Object |
getConnectionID() |
long |
getCreationTime() |
List<MessageReference> |
getDeliveringReferencesBasedOnProtocol(boolean remove,
Object protocolDataStart,
Object protocolDataEnd) |
long |
getID() |
Object |
getProtocolContext()
An object set by the Protocol implementation.
|
Object |
getProtocolData()
this is to be used with anything specific on a protocol head.
|
Queue |
getQueue() |
String |
getSessionID() |
SlowConsumerDetectionListener |
getSlowConsumerDetecion() |
void |
individualAcknowledge(Transaction tx,
long messageID) |
void |
individualCancel(long messageID,
boolean failed) |
boolean |
isBrowseOnly() |
void |
receiveCredits(int credits) |
void |
reject(long messageID) |
void |
removeItself()
This method is just to remove itself from Queues.
|
MessageReference |
removeReferenceByID(long messageID) |
void |
setlowConsumerDetection(SlowConsumerDetectionListener listener) |
void |
setProtocolContext(Object protocolContext) |
void |
setProtocolData(Object protocolData)
this is to be used with anything specific on a protocol head.
|
void |
setStarted(boolean started) |
void |
setTransferring(boolean transferring) |
debug, disconnect, errorProcessing, getDeliveringMessages, getFilter, getPriority, handle, proceedDeliver, promptDelivery, sequentialID, supportsDirectDelivery, toManagementString
getConnectionClientID, getConnectionLocalAddress, getConnectionProtocolName, getConnectionRemoteAddress, getFilterString, getQueueAddress, getQueueName, getQueueType, getSequentialID, getSessionName
void setlowConsumerDetection(SlowConsumerDetectionListener listener)
SlowConsumerDetectionListener getSlowConsumerDetecion()
void fireSlowConsumer()
boolean allowReferenceCallback()
Object getProtocolData()
void setProtocolData(Object protocolData)
void setProtocolContext(Object protocolContext)
protocolContext
- getProtocolContext()
Object getProtocolContext()
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)
void receiveCredits(int credits)
Queue getQueue()
MessageReference removeReferenceByID(long messageID) throws Exception
Exception
void backToDelivering(MessageReference reference)
List<MessageReference> getDeliveringReferencesBasedOnProtocol(boolean remove, Object protocolDataStart, Object protocolDataEnd)
void acknowledge(Transaction tx, long messageID) throws Exception
Exception
void individualAcknowledge(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 © 2019 JBoss by Red Hat. All rights reserved.