org.jacorb.notification.servant
public class ProxyPullConsumerImpl extends AbstractProxyConsumer implements ProxyPullConsumerOperations, MessageSupplier, MessageSupplierDelegate, ProxyPullConsumerImplMBean
Version: $Id: ProxyPullConsumerImpl.java,v 1.16 2006/01/12 22:34:54 alphonse.bendt Exp $
UNKNOWN: extends = "AbstractProxyConsumerMBean"
Constructor Summary | |
---|---|
ProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager) |
Method Summary | |
---|---|
protected void | connectionResumed() |
protected void | connectionSuspended() |
void | connect_any_pull_supplier(PullSupplier pullSupplier) |
protected void | disconnectClient() |
void | disconnect_pull_consumer() |
long | getPollInterval() |
int | getPullCounter() |
long | getPullTimer() |
int | getSuccessfulPullCounter() |
ProxyType | MyType() |
Servant | newServant() |
MessageSupplierDelegate.PullResult | pullMessages() |
void | queueMessages(PullResult data) |
void | runPullMessage() |