Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq.server
Class ClientConsumer

java.lang.Object
  extended byorg.jboss.mq.server.ClientConsumer
All Implemented Interfaces:
Work (src)
public class ClientConsumer
extends java.lang.Object
implements Work (src)

This represent the clients queue which consumes messages from the destinations on the provider.

Constructor Summary
ClientConsumer(JMSDestinationManager (src)  server, ConnectionToken (src)  connectionToken)
           
 
Method Summary
 void acknowledge(AcknowledgementRequest (src)  request, Tx (src)  txId)
           
 void addSubscription(Subscription (src)  req)
           
 void close()
           
 void doWork()
          Push some messages.
 Subscription (src) getSubscription(int subscriberId)
          Get a subscription for the subscriberid
 void queueMessageForSending(RoutedMessage (src)  r)
           
 SpyMessage (src) receive(int subscriberId, long wait)
           
 void removeSubscription(int subscriptionId)
           
 void setEnabled(boolean enabled)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ClientConsumer

public ClientConsumer(JMSDestinationManager (src)  server,
                      ConnectionToken (src)  connectionToken)
               throws JMSException (src)
Method Detail

setEnabled

public void setEnabled(boolean enabled)
                throws JMSException (src)
Throws:
JMSException (src)

queueMessageForSending

public void queueMessageForSending(RoutedMessage (src)  r)

addSubscription

public void addSubscription(Subscription (src)  req)
                     throws JMSException (src)
Throws:
JMSException (src)

close

public void close()

receive

public SpyMessage (src)  receive(int subscriberId,
                          long wait)
                   throws JMSException (src)
Throws:
JMSException (src)

removeSubscription

public void removeSubscription(int subscriptionId)
                        throws JMSException (src)
Throws:
JMSException (src)

doWork

public void doWork()
Push some messages.

Specified by:
doWork in interface Work (src)

toString

public java.lang.String toString()

acknowledge

public void acknowledge(AcknowledgementRequest (src)  request,
                        Tx (src)  txId)
                 throws JMSException (src)
Throws:
JMSException (src)

getSubscription

public Subscription (src)  getSubscription(int subscriberId)
                             throws JMSException (src)
Get a subscription for the subscriberid

Throws:
JMSException (src) - if it can not find the subscription.
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD