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 and Description
AMQConsumer(AMQSession amqSession, org.apache.activemq.command.ActiveMQDestination d, org.apache.activemq.command.ConsumerInfo info, ScheduledExecutorService scheduledPool)

Method Summary

Modifier and Type	Method and Description
void	acknowledge(org.apache.activemq.command.MessageAck ack) The acknowledgement in openwire is done based on intervals.
void	acquireCredit(int n)
void	browseFinished()
org.apache.activemq.command.ConsumerId	getId()
org.apache.activemq.command.ConsumerInfo	getInfo()
org.apache.activemq.wireformat.WireFormat	getMarshaller()
org.apache.activemq.command.ActiveMQDestination	getOpenwireDestination()
int	handleDeliver(MessageReference reference, ServerMessage message, int deliveryCount)
void	handleDeliverNullDispatch()
boolean	hasCredits()
void	init(SlowConsumerDetectionListener slowConsumerDetectionListener, long nativeId)
void	processMessagePull(org.apache.activemq.command.MessagePull messagePull)
void	removeConsumer()
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)

Method Detail

init

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

Throws:

Exception

getId

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

getMarshaller

public org.apache.activemq.wireformat.WireFormat getMarshaller()

acquireCredit

public void acquireCredit(int n)
                   throws Exception

Throws:

Exception

handleDeliver

public int handleDeliver(MessageReference reference,
                         ServerMessage message,
                         int deliveryCount)

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.getDeliveringReferencesBasedOnProtocol(boolean, Object, Object) 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)