Package org.apache.activemq.artemis.core.client.impl

Interface ClientConsumerInternal

All Superinterfaces:

AutoCloseable, ClientConsumer

All Known Implementing Classes:

ClientConsumerImpl

public interface ClientConsumerInternal
extends ClientConsumer

Method Summary

Modifier and Type	Method	Description
void	acknowledge(ClientMessage message)
void	cleanUp()
void	clear(boolean waitForOnMessage)
void	clearAtFailover()
void	flowControl(int messageBytes, boolean discountSlowConsumer)
void	flushAcks()
int	getBufferSize()
int	getClientWindowSize()
Thread	getCurrentThread()
SimpleString	getFilterString()
long	getForceDeliveryCount()
int	getInitialWindowSize()
int	getPriority()
ClientSession.QueueQuery	getQueueInfo()
SimpleString	getQueueName()
void	handleLargeMessage(ClientLargeMessageInternal clientLargeMessage, long largeMessageSize)
void	handleLargeMessageContinuation(byte[] chunk, int flowControlSize, boolean isContinues)
void	handleMessage(ClientMessageInternal message)
void	individualAcknowledge(ClientMessage message)
boolean	isBrowseOnly()
Thread	prepareForClose(FutureLatch future)	To be called by things like MDBs during shutdown of the server
void	resetIfSlowConsumer()
ClientConsumer	setManualFlowMessageHandler(MessageHandler theHandler)
void	start()
void	stop(boolean waitForOnMessage)

Methods inherited from interface org.apache.activemq.artemis.api.core.client.ClientConsumer

close, getConsumerContext, getLastException, getMessageHandler, isClosed, receive, receive, receiveImmediate, setMessageHandler

Method Details

getQueueName

SimpleString getQueueName()

getFilterString

SimpleString getFilterString()

getPriority

int getPriority()

isBrowseOnly

boolean isBrowseOnly()

handleMessage

void handleMessage(ClientMessageInternal message)
            throws Exception

Throws:

Exception

handleLargeMessage

void handleLargeMessage(ClientLargeMessageInternal clientLargeMessage,
 long largeMessageSize)
                 throws Exception

Throws:

Exception

handleLargeMessageContinuation

void handleLargeMessageContinuation(byte[] chunk,
 int flowControlSize,
 boolean isContinues)
                             throws Exception

Throws:

Exception

flowControl

void flowControl(int messageBytes,
 boolean discountSlowConsumer)
          throws ActiveMQException

Throws:

ActiveMQException

clear

void clear(boolean waitForOnMessage)
    throws ActiveMQException

Throws:

ActiveMQException

getCurrentThread

Thread getCurrentThread()

prepareForClose

Thread prepareForClose(FutureLatch future)
                throws ActiveMQException

To be called by things like MDBs during shutdown of the server

Throws:

ActiveMQException

clearAtFailover

void clearAtFailover()

getClientWindowSize

int getClientWindowSize()

getInitialWindowSize

int getInitialWindowSize()

getBufferSize

int getBufferSize()

cleanUp

void cleanUp()
      throws ActiveMQException

Throws:

ActiveMQException

acknowledge

void acknowledge(ClientMessage message)
          throws ActiveMQException

Throws:

ActiveMQException

individualAcknowledge

void individualAcknowledge(ClientMessage message)
                    throws ActiveMQException

Throws:

ActiveMQException

flushAcks

void flushAcks()
        throws ActiveMQException

Throws:

ActiveMQException

stop

void stop(boolean waitForOnMessage)
   throws ActiveMQException

Throws:

ActiveMQException

start

void start()

getQueueInfo

ClientSession.QueueQuery getQueueInfo()

getForceDeliveryCount

long getForceDeliveryCount()

setManualFlowMessageHandler

ClientConsumer setManualFlowMessageHandler(MessageHandler theHandler)
                                    throws ActiveMQException

Throws:

ActiveMQException

resetIfSlowConsumer

void resetIfSlowConsumer()