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() |