| java.lang.Object org.jboss.mq.server.ClientConsumer
ClientConsumer | public class ClientConsumer implements Runnable(Code) | | This represent the clients queue which consumes messages from the
destinations on the provider.
author: Hiram Chirino (Cojonudo14@hotmail.com) author: Peter Antman version: $Revision: 57198 $ |
close | public void close()(Code) | | |
getSubscription | public Subscription getSubscription(int subscriberId) throws JMSException(Code) | | Get a subscription for the subscriberid
exception: JMSException - if it can not find the subscription. |
receive | public SpyMessage receive(int subscriberId, long wait) throws JMSException(Code) | | |
removeRemovedSubscription | void removeRemovedSubscription(int subId)(Code) | | |
removeSubscription | public void removeSubscription(int subscriptionId) throws JMSException(Code) | | |
run | public void run()(Code) | | Push some messages.
|
setEnabled | public void setEnabled(boolean enabled) throws JMSException(Code) | | |
|
|