public class ServerConsumerImpl extends Object implements ServerConsumer, ReadyListener
Constructor and Description |
---|
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService) |
ServerConsumerImpl(long id,
ServerSession session,
QueueBinding binding,
Filter filter,
boolean started,
boolean browseOnly,
StorageManager storageManager,
SessionCallback callback,
boolean preAcknowledge,
boolean strictUpdateDeliveryCount,
ManagementService managementService,
boolean supportLargeMessage,
Integer credits) |
Modifier and Type | Method and Description |
---|---|
void |
acknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
LinkedList<MessageReference> |
cancelRefs(boolean failed,
boolean lastConsumedAsDelivered,
Transaction tx) |
void |
close(boolean failed) |
String |
debug() |
void |
disconnect()
disconnect the consumer
|
void |
forceDelivery(long sequence)
Prompt delivery and send a "forced delivery" message to the consumer.
|
AtomicInteger |
getAvailableCredits()
To be used on tests only
|
String |
getConnectionID() |
long |
getCreationTime() |
List<MessageReference> |
getDeliveringMessages()
Add the in-deliver mode messages to the ref-list passed as parameter
|
Filter |
getFilter() |
long |
getID() |
Queue |
getQueue() |
float |
getRate() |
String |
getSessionID() |
HandleStatus |
handle(MessageReference ref)
There was a change on semantic during 2.3 here.
We now first accept the message, and the actual deliver is done as part of Consumer.proceedDeliver(MessageReference) . |
void |
individualAcknowledge(boolean autoCommitAcks,
Transaction tx,
long messageID) |
void |
individualCancel(long messageID,
boolean failed) |
boolean |
isBrowseOnly() |
void |
proceedDeliver(MessageReference reference)
This will proceed with the actual delivery.
|
void |
readyForWriting(boolean ready) |
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) |
String |
toManagementString()
This method will create a string representation meant for management operations.
|
String |
toString() |
public ServerConsumerImpl(long id, ServerSession session, QueueBinding binding, Filter filter, boolean started, boolean browseOnly, StorageManager storageManager, SessionCallback callback, boolean preAcknowledge, boolean strictUpdateDeliveryCount, ManagementService managementService) throws Exception
Exception
public ServerConsumerImpl(long id, ServerSession session, QueueBinding binding, Filter filter, boolean started, boolean browseOnly, StorageManager storageManager, SessionCallback callback, boolean preAcknowledge, boolean strictUpdateDeliveryCount, ManagementService managementService, boolean supportLargeMessage, Integer credits) throws Exception
Exception
public long getID()
getID
in interface ServerConsumer
public boolean isBrowseOnly()
isBrowseOnly
in interface ServerConsumer
public long getCreationTime()
getCreationTime
in interface ServerConsumer
public String getConnectionID()
getConnectionID
in interface ServerConsumer
public String getSessionID()
getSessionID
in interface ServerConsumer
public List<MessageReference> getDeliveringMessages()
Consumer
getDeliveringMessages
in interface Consumer
public HandleStatus handle(MessageReference ref) throws Exception
Consumer
Consumer.proceedDeliver(MessageReference)
. This is to avoid holding a lock on the queues while
the delivery is being accomplished To avoid a lock on the queue in case of misbehaving
consumers.
This should return busy if handle is called before proceed deliver is called
public void proceedDeliver(MessageReference reference) throws Exception
Consumer
proceedDeliver
in interface Consumer
Exception
public void close(boolean failed) throws Exception
close
in interface ServerConsumer
Exception
public void removeItself() throws Exception
ServerConsumer
removeItself
in interface ServerConsumer
Exception
public void forceDelivery(long sequence)
forceDelivery
in interface ServerConsumer
public LinkedList<MessageReference> cancelRefs(boolean failed, boolean lastConsumedAsDelivered, Transaction tx) throws Exception
cancelRefs
in interface ServerConsumer
Exception
public void setStarted(boolean started)
setStarted
in interface ServerConsumer
public void setTransferring(boolean transferring)
setTransferring
in interface ServerConsumer
public void receiveCredits(int credits) throws Exception
receiveCredits
in interface ServerConsumer
Exception
public Queue getQueue()
getQueue
in interface ServerConsumer
public void acknowledge(boolean autoCommitAcks, Transaction tx, long messageID) throws Exception
acknowledge
in interface ServerConsumer
Exception
public void individualAcknowledge(boolean autoCommitAcks, Transaction tx, long messageID) throws Exception
individualAcknowledge
in interface ServerConsumer
Exception
public void individualCancel(long messageID, boolean failed) throws Exception
individualCancel
in interface ServerConsumer
Exception
public MessageReference removeReferenceByID(long messageID) throws Exception
removeReferenceByID
in interface ServerConsumer
Exception
public void readyForWriting(boolean ready)
readyForWriting
in interface ReadyListener
public AtomicInteger getAvailableCredits()
public String toManagementString()
Consumer
toManagementString
in interface Consumer
public void disconnect()
Consumer
disconnect
in interface Consumer
public float getRate()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.