Package org.apache.activemq.artemis.core.protocol.openwire.amq

Class AMQConsumer

java.lang.Object

org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer

public class AMQConsumer
extends Object

Constructor Summary

Constructors

Constructor	Description
AMQConsumer(AMQSession amqSession, org.apache.activemq.command.ActiveMQDestination d, org.apache.activemq.command.ConsumerInfo info, ScheduledExecutorService scheduledPool, boolean internalAddress)

Method Summary

Modifier and Type	Method	Description
void	acknowledge(org.apache.activemq.command.MessageAck ack)	The acknowledgement in openwire is done based on intervals.
void	acquireCredit(int n, boolean delivered)
void	addRolledback(MessageReference messageReference)
void	browseFinished()
org.apache.activemq.command.ConsumerId	getId()
org.apache.activemq.command.ConsumerInfo	getInfo()
org.apache.activemq.command.ActiveMQDestination	getOpenwireDestination()
protected Set<MessageReference>	getRolledbackMessageRefs()
int	handleDeliver(MessageReference reference, ICoreMessage message)
void	handleDeliverNullDispatch()
boolean	hasCredits()
void	init(SlowConsumerDetectionListener slowConsumerDetectionListener, long nativeId)
void	processMessagePull(org.apache.activemq.command.MessagePull messagePull)
void	removeConsumer()
void	removeRolledback(MessageReference messageReference)
void	setPrefetchSize(int prefetchSize)
boolean	updateDeliveryCountAfterCancel(MessageReference ref)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQConsumer

public AMQConsumer(AMQSession amqSession,
                   org.apache.activemq.command.ActiveMQDestination d,
                   org.apache.activemq.command.ConsumerInfo info,
                   ScheduledExecutorService scheduledPool,
                   boolean internalAddress)

Method Detail

getRolledbackMessageRefs

protected Set<MessageReference> getRolledbackMessageRefs()

init

public void init(SlowConsumerDetectionListener slowConsumerDetectionListener,
                 long nativeId)
          throws Exception

Throws:

Exception

getId

public org.apache.activemq.command.ConsumerId getId()

acquireCredit

public void acquireCredit(int n,
                          boolean delivered)

handleDeliver

public int handleDeliver(MessageReference reference,
                         ICoreMessage message)

handleDeliverNullDispatch

public void handleDeliverNullDispatch()

acknowledge

public void acknowledge(org.apache.activemq.command.MessageAck ack)
                 throws Exception

The acknowledgement in openwire is done based on intervals. We will iterate through the list of delivering messages at ServerConsumer.scanDeliveringReferences(boolean, Function, Function) and add those to the Transaction. Notice that we will start a new transaction on the cases where there is no transaction.

Throws:

Exception

browseFinished

public void browseFinished()

getInfo

public org.apache.activemq.command.ConsumerInfo getInfo()

hasCredits

public boolean hasCredits()

processMessagePull

public void processMessagePull(org.apache.activemq.command.MessagePull messagePull)
                        throws Exception

Throws:

Exception

removeConsumer

public void removeConsumer()
                    throws Exception

Throws:

Exception

getOpenwireDestination

public org.apache.activemq.command.ActiveMQDestination getOpenwireDestination()

setPrefetchSize

public void setPrefetchSize(int prefetchSize)

updateDeliveryCountAfterCancel

public boolean updateDeliveryCountAfterCancel(MessageReference ref)

removeRolledback

public void removeRolledback(MessageReference messageReference)

addRolledback

public void addRolledback(MessageReference messageReference)