org.apache.activemq.artemis.core.server.impl

Class ServerConsumerImpl

java.lang.Object

org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl

All Implemented Interfaces:

Consumer, ServerConsumer, ReadyListener

public class ServerConsumerImpl
extends Object
implements ServerConsumer, ReadyListener

Concrete implementation of a ClientConsumer.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ServerConsumerImpl.BrowserDeliverer

Field Summary

Fields

Modifier and Type	Field and Description
protected ServerConsumerImpl.BrowserDeliverer	browserDeliverer
protected Deque<MessageReference>	deliveringRefs
protected Object	lock
protected Queue	messageQueue

Constructor Summary

Constructors

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, ActiveMQServer server)
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, ActiveMQServer server)

Method Summary

Modifier and Type	Method and Description
void	acknowledge(Transaction tx, long messageID)
void	backToDelivering(MessageReference reference) Some protocols may choose to send the message back to delivering instead of redeliver.
LinkedList<MessageReference>	cancelRefs(boolean failed, boolean lastConsumedAsDelivered, Transaction tx)
void	close(boolean failed)
String	debug()
void	disconnect() disconnect the consumer
void	fireSlowConsumer()
void	forceDelivery(long sequence) Prompt delivery and send a "forced delivery" message to the consumer.
void	forceDelivery(long sequence, Runnable r)
AtomicInteger	getAvailableCredits() To be used on tests only
String	getConnectionID()
long	getCreationTime()
List<MessageReference>	getDeliveringMessages()
List<MessageReference>	getDeliveringReferencesBasedOnProtocol(boolean remove, Object protocolDataStart, Object protocolDataEnd) Remove references based on the protocolData.
Filter	getFilter()
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()
float	getRate()
String	getSessionID()
SlowConsumerDetectionListener	getSlowConsumerDetecion()
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(Transaction tx, long messageID)
void	individualCancel(long messageID, boolean failed)
boolean	isBrowseOnly()
void	proceedDeliver(MessageReference reference) This will proceed with the actual delivery.
void	promptDelivery()
void	readyForWriting()
void	receiveCredits(int credits)
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)
String	toManagementString() This method will create a string representation meant for management operations.
String	toString()
protected void	updateDeliveryCountForCanceledRef(MessageReference ref, boolean failed)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

messageQueue

protected final Queue messageQueue

lock

protected final Object lock

browserDeliverer

protected ServerConsumerImpl.BrowserDeliverer browserDeliverer

deliveringRefs

protected final Deque<MessageReference> deliveringRefs

Constructor Detail

ServerConsumerImpl

public ServerConsumerImpl(long id,
                          ServerSession session,
                          QueueBinding binding,
                          Filter filter,
                          boolean started,
                          boolean browseOnly,
                          StorageManager storageManager,
                          SessionCallback callback,
                          boolean preAcknowledge,
                          boolean strictUpdateDeliveryCount,
                          ManagementService managementService,
                          ActiveMQServer server)
                   throws Exception

Throws:

Exception

ServerConsumerImpl

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,
                          ActiveMQServer server)
                   throws Exception

Throws:

Exception

Method Detail

debug

public String debug()

Specified by:

debug in interface Consumer

readyForWriting

public void readyForWriting()

Specified by:

readyForWriting in interface ReadyListener

getProtocolData

public Object getProtocolData()

Description copied from interface: ServerConsumer

this is to be used with anything specific on a protocol head.

Specified by:

getProtocolData in interface ServerConsumer

setProtocolData

public void setProtocolData(Object protocolData)

Description copied from interface: ServerConsumer

this is to be used with anything specific on a protocol head.

Specified by:

setProtocolData in interface ServerConsumer

setlowConsumerDetection

public void setlowConsumerDetection(SlowConsumerDetectionListener listener)

Specified by:

setlowConsumerDetection in interface ServerConsumer

getSlowConsumerDetecion

public SlowConsumerDetectionListener getSlowConsumerDetecion()

Specified by:

getSlowConsumerDetecion in interface ServerConsumer

fireSlowConsumer

public void fireSlowConsumer()

Specified by:

fireSlowConsumer in interface ServerConsumer

getProtocolContext

public Object getProtocolContext()

Description copied from interface: ServerConsumer

An object set by the Protocol implementation. it could be anything pre-determined by the implementation

Specified by:

getProtocolContext in interface ServerConsumer

setProtocolContext

public void setProtocolContext(Object protocolContext)

Specified by:

setProtocolContext in interface ServerConsumer

See Also:

ServerConsumer.getProtocolContext()

getID

public long getID()

Specified by:

getID in interface ServerConsumer

isBrowseOnly

public boolean isBrowseOnly()

Specified by:

isBrowseOnly in interface ServerConsumer

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface ServerConsumer

getConnectionID

public String getConnectionID()

Specified by:

getConnectionID in interface ServerConsumer

getSessionID

public String getSessionID()

Specified by:

getSessionID in interface ServerConsumer

getDeliveringMessages

public List<MessageReference> getDeliveringMessages()

Specified by:

getDeliveringMessages in interface Consumer

Returns:

the list of messages being delivered

handle

public HandleStatus handle(MessageReference ref)
                    throws Exception

Description copied from interface: Consumer

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). 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

Specified by:

handle in interface Consumer

Returns:

Throws:

Exception

proceedDeliver

public void proceedDeliver(MessageReference reference)
                    throws Exception

Description copied from interface: Consumer

This will proceed with the actual delivery. Notice that handle should hold a readLock and proceedDelivery should release the readLock any lock operation on Consumer should also get a writeLock on the readWriteLock to guarantee there are no pending deliveries

Specified by:

proceedDeliver in interface Consumer

Throws:

Exception

getFilter

public Filter getFilter()

Specified by:

getFilter in interface Consumer

close

public void close(boolean failed)
           throws Exception

Specified by:

close in interface ServerConsumer

Throws:

Exception

removeItself

public void removeItself()
                  throws Exception

Description copied from interface: ServerConsumer

This method is just to remove itself from Queues. If for any reason during a close an exception occurred, the exception treatment will call removeItself what should take the consumer out of any queues.

Specified by:

removeItself in interface ServerConsumer

Throws:

Exception

forceDelivery

public void forceDelivery(long sequence)

Prompt delivery and send a "forced delivery" message to the consumer.

When the consumer receives such a "forced delivery" message, it discards it and knows that there are no other messages to be delivered.

Specified by:

forceDelivery in interface ServerConsumer

forceDelivery

public void forceDelivery(long sequence,
                          Runnable r)

cancelRefs

public LinkedList<MessageReference> cancelRefs(boolean failed,
                                               boolean lastConsumedAsDelivered,
                                               Transaction tx)
                                        throws Exception

Specified by:

cancelRefs in interface ServerConsumer

Throws:

Exception

updateDeliveryCountForCanceledRef

protected void updateDeliveryCountForCanceledRef(MessageReference ref,
                                                 boolean failed)

setStarted

public void setStarted(boolean started)

Specified by:

setStarted in interface ServerConsumer

setTransferring

public void setTransferring(boolean transferring)

Specified by:

setTransferring in interface ServerConsumer

receiveCredits

public void receiveCredits(int credits)

Specified by:

receiveCredits in interface ServerConsumer

getQueue

public Queue getQueue()

Specified by:

getQueue in interface ServerConsumer

getDeliveringReferencesBasedOnProtocol

public List<MessageReference> getDeliveringReferencesBasedOnProtocol(boolean remove,
                                                                     Object protocolDataStart,
                                                                     Object protocolDataEnd)

Remove references based on the protocolData. there will be an interval defined between protocolDataStart and protocolDataEnd. This method will fetch the delivering references, remove them from the delivering list and return a list. This will be useful for other protocols that will need this such as openWire or MQTT.

Specified by:

getDeliveringReferencesBasedOnProtocol in interface ServerConsumer

acknowledge

public void acknowledge(Transaction tx,
                        long messageID)
                 throws Exception

Specified by:

acknowledge in interface ServerConsumer

Throws:

Exception

individualAcknowledge

public void individualAcknowledge(Transaction tx,
                                  long messageID)
                           throws Exception

Specified by:

individualAcknowledge in interface ServerConsumer

Throws:

Exception

individualCancel

public void individualCancel(long messageID,
                             boolean failed)
                      throws Exception

Specified by:

individualCancel in interface ServerConsumer

Throws:

Exception

backToDelivering

public void backToDelivering(MessageReference reference)

Description copied from interface: ServerConsumer

Some protocols may choose to send the message back to delivering instead of redeliver. For example openwire will redeliver through the client, so messages will go back to delivering list after rollback.

Specified by:

backToDelivering in interface ServerConsumer

removeReferenceByID

public MessageReference removeReferenceByID(long messageID)
                                     throws Exception

Specified by:

removeReferenceByID in interface ServerConsumer

Throws:

Exception

getAvailableCredits

public AtomicInteger getAvailableCredits()

To be used on tests only

toString

public String toString()

Overrides:

toString in class Object

toManagementString

public String toManagementString()

Description copied from interface: Consumer

This method will create a string representation meant for management operations. This is different from the toString method that's meant for debugging and will contain information that regular users won't understand well

Specified by:

toManagementString in interface Consumer

Returns:

disconnect

public void disconnect()

Description copied from interface: Consumer

disconnect the consumer

Specified by:

disconnect in interface Consumer

getRate

public float getRate()

promptDelivery

public void promptDelivery()

Specified by:

promptDelivery in interface ServerConsumer