org.jboss.messaging.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
 void acknowledge(ClientMessage message)
           
 void cleanUp()
           
 void clear()
           
 void flowControl(int messageBytes, boolean discountSlowConsumer)
           
 void flushAcks()
           
 int getBufferSize()
           
 int getClientWindowSize()
           
 long getID()
           
 void handleLargeMessage(SessionReceiveMessage largeMessageHeader)
           
 void handleLargeMessageContinuation(SessionReceiveContinuationMessage continuation)
           
 void handleMessage(ClientMessageInternal message)
           
 boolean isFileConsumer()
           
 void start()
           
 void stop()
           
 
Methods inherited from interface org.jboss.messaging.core.client.ClientConsumer
close, getLastException, getMessageHandler, isClosed, receive, receive, receiveImmediate, setMessageHandler
 

Method Detail

getID

long getID()

handleMessage

void handleMessage(ClientMessageInternal message)
                   throws java.lang.Exception
Throws:
java.lang.Exception

handleLargeMessage

void handleLargeMessage(SessionReceiveMessage largeMessageHeader)
                        throws java.lang.Exception
Throws:
java.lang.Exception

handleLargeMessageContinuation

void handleLargeMessageContinuation(SessionReceiveContinuationMessage continuation)
                                    throws java.lang.Exception
Throws:
java.lang.Exception

flowControl

void flowControl(int messageBytes,
                 boolean discountSlowConsumer)
                 throws MessagingException
Throws:
MessagingException

clear

void clear()

getClientWindowSize

int getClientWindowSize()

getBufferSize

int getBufferSize()

cleanUp

void cleanUp()
             throws MessagingException
Throws:
MessagingException

acknowledge

void acknowledge(ClientMessage message)
                 throws MessagingException
Throws:
MessagingException

flushAcks

void flushAcks()
               throws MessagingException
Throws:
MessagingException

isFileConsumer

boolean isFileConsumer()

stop

void stop()
          throws MessagingException
Throws:
MessagingException

start

void start()


Copyright © 2006 JBoss Inc. All Rights Reserved.