org.hornetq.core.client.impl

Interface ClientConsumerInternal

All Superinterfaces:

AutoCloseable, ClientConsumer

All Known Implementing Classes:

ClientConsumerImpl

public interface ClientConsumerInternal
extends ClientConsumer

A ClientConsumerInternal

Author:

Tim Fox

Method Summary

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)
boolean	isBrowseOnly()
Thread	prepareForClose(FutureLatch future) To be called by things like MDBs during shutdown of the server
void	start()
void	stop(boolean waitForOnMessage)

Methods inherited from interface org.hornetq.api.core.client.ClientConsumer

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

Method Detail

getID

long getID()

getQueueName

SimpleString getQueueName()

getFilterString

SimpleString getFilterString()

isBrowseOnly

boolean isBrowseOnly()

handleMessage

void handleMessage(SessionReceiveMessage message)
            throws Exception

Throws:

Exception

handleLargeMessage

void handleLargeMessage(SessionReceiveLargeMessage largeMessageHeader)
                 throws Exception

Throws:

Exception

handleLargeMessageContinuation

void handleLargeMessageContinuation(SessionReceiveContinuationMessage continuation)
                             throws Exception

Throws:

Exception

flowControl

void flowControl(int messageBytes,
                 boolean discountSlowConsumer)
          throws HornetQException

Throws:

HornetQException

clear

void clear(boolean waitForOnMessage)
    throws HornetQException

Throws:

HornetQException

prepareForClose

Thread prepareForClose(FutureLatch future)
                throws HornetQException

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

Parameters:

future -

Throws:

HornetQException

clearAtFailover

void clearAtFailover()

getClientWindowSize

int getClientWindowSize()

getBufferSize

int getBufferSize()

cleanUp

void cleanUp()
      throws HornetQException

Throws:

HornetQException

acknowledge

void acknowledge(ClientMessage message)
          throws HornetQException

Throws:

HornetQException

individualAcknowledge

void individualAcknowledge(ClientMessage message)
                    throws HornetQException

Throws:

HornetQException

flushAcks

void flushAcks()
        throws HornetQException

Throws:

HornetQException

stop

void stop(boolean waitForOnMessage)
   throws HornetQException

Throws:

HornetQException

start

void start()

getQueueInfo

SessionQueueQueryResponseMessage getQueueInfo()