public interface ClientConsumerInternal extends ClientConsumer
Modifier and Type | Method and 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() |
SimpleString |
getFilterString() |
long |
getID() |
SessionQueueQueryResponseMessage |
getQueueInfo() |
SimpleString |
getQueueName() |
void |
handleLargeMessage(SessionReceiveLargeMessage largeMessageHeader) |
void |
handleLargeMessageContinuation(SessionReceiveContinuationMessage continuation) |
void |
handleMessage(SessionReceiveMessage message) |
void |
individualAcknowledge(ClientMessage message) |
void |
interruptHandlers()
To be called by things like MDBs during shutdown of the server
|
boolean |
isBrowseOnly() |
void |
start() |
void |
stop(boolean waitForOnMessage) |
close, getLastException, getMessageHandler, isClosed, receive, receive, receiveImmediate, setMessageHandler
long getID()
SimpleString getQueueName()
SimpleString getFilterString()
boolean isBrowseOnly()
void handleMessage(SessionReceiveMessage message) throws Exception
Exception
void handleLargeMessage(SessionReceiveLargeMessage largeMessageHeader) throws Exception
Exception
void handleLargeMessageContinuation(SessionReceiveContinuationMessage continuation) throws Exception
Exception
void flowControl(int messageBytes, boolean discountSlowConsumer) throws HornetQException
HornetQException
void clear(boolean waitForOnMessage) throws HornetQException
HornetQException
void interruptHandlers() throws HornetQException
interrupt
- HornetQException
void clearAtFailover()
int getClientWindowSize()
int getBufferSize()
void cleanUp() throws HornetQException
HornetQException
void acknowledge(ClientMessage message) throws HornetQException
HornetQException
void individualAcknowledge(ClientMessage message) throws HornetQException
HornetQException
void flushAcks() throws HornetQException
HornetQException
void stop(boolean waitForOnMessage) throws HornetQException
HornetQException
void start()
SessionQueueQueryResponseMessage getQueueInfo()
Copyright © 2014 JBoss by Red Hat. All Rights Reserved.