org.jacorb.notification.servant
public class StructuredProxyPullConsumerImpl extends AbstractProxyConsumer implements StructuredProxyPullConsumerOperations, MessageSupplier, MessageSupplierDelegate, StructuredProxyPullConsumerImplMBean
Version: $Id: StructuredProxyPullConsumerImpl.java,v 1.17 2006/01/12 22:34:54 alphonse.bendt Exp $
UNKNOWN: extends ="AbstractProxyConsumerMBean"
Constructor Summary | |
---|---|
StructuredProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration config, TaskProcessor taskProcessor, MessageFactory mf, OfferManager offerManager, SubscriptionManager subscriptionManager, SupplierAdmin supplierAdmin) |
Method Summary | |
---|---|
void | connectionResumed() |
protected void | connectionSuspended() |
void | connect_structured_pull_supplier(StructuredPullSupplier pullSupplier) |
protected void | disconnectClient() |
void | disconnect_structured_pull_consumer() |
ProxyType | MyType() |
Servant | newServant() |
MessageSupplierDelegate.PullResult | pullMessages() |
void | queueMessages(PullResult data) |
void | runPullMessage() |
protected void | startTask() |
protected void | stopTask() |