Interface ClientConsumerInternal
- All Superinterfaces:
AutoCloseable,ClientConsumer
- All Known Implementing Classes:
ClientConsumerImpl
-
Method Summary
Modifier and TypeMethodDescriptionvoidacknowledge(ClientMessage message) voidcleanUp()voidclear(boolean waitForOnMessage) voidvoidflowControl(int messageBytes, boolean discountSlowConsumer) voidintintlongintintvoidhandleLargeMessage(ClientLargeMessageInternal clientLargeMessage, long largeMessageSize) voidhandleLargeMessageContinuation(byte[] chunk, int flowControlSize, boolean isContinues) voidhandleMessage(ClientMessageInternal message) voidindividualAcknowledge(ClientMessage message) booleanprepareForClose(FutureLatch future) To be called by things like MDBs during shutdown of the servervoidsetManualFlowMessageHandler(MessageHandler theHandler) voidstart()voidstop(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
- 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
- Throws:
ActiveMQException
-
clear
- Throws:
ActiveMQException
-
getCurrentThread
Thread getCurrentThread() -
prepareForClose
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
- Throws:
ActiveMQException
-
acknowledge
- Throws:
ActiveMQException
-
individualAcknowledge
- Throws:
ActiveMQException
-
flushAcks
- Throws:
ActiveMQException
-
stop
- Throws:
ActiveMQException
-
start
void start() -
getQueueInfo
ClientSession.QueueQuery getQueueInfo() -
getForceDeliveryCount
long getForceDeliveryCount() -
setManualFlowMessageHandler
- Throws:
ActiveMQException
-
resetIfSlowConsumer
void resetIfSlowConsumer()
-