org.jboss.mq.server
Class ClientConsumer
java.lang.Object
org.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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
ClientConsumer
public ClientConsumer(JMSDestinationManager (src) server,
ConnectionToken (src) connectionToken)
throws JMSException (src)
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.