org.hornetq.core.client.impl

Interface ClientConsumerInternal

All Superinterfaces:

ClientConsumer

All Known Implementing Classes:

ClientConsumerImpl

public interface ClientConsumerInternal
extends ClientConsumer

A ClientConsumerInternal

Author:

Tim Fox

Method Summary

Methods

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()
ClientSessionInternal	getSession()
void	handleLargeMessage(SessionReceiveLargeMessage largeMessageHeader)
void	handleLargeMessageContinuation(SessionReceiveContinuationMessage continuation)
void	handleMessage(ClientMessageInternal message)
boolean	isBrowseOnly()
void	start()
void	stop()
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(ClientMessageInternal 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

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

flushAcks

void flushAcks()
               throws HornetQException

Throws:

HornetQException

stop

void stop()
          throws HornetQException

Throws:

HornetQException

stop

void stop(boolean waitForOnMessage)
          throws HornetQException

Throws:

HornetQException

start

void start()

getQueueInfo

SessionQueueQueryResponseMessage getQueueInfo()

getSession

ClientSessionInternal getSession()