org.jacorb.notification.servant
public class SequenceProxyPullConsumerImpl extends AbstractProxyConsumer implements SequenceProxyPullConsumerOperations, SequenceProxyPullConsumerImplMBean, MessageSupplier, MessageSupplierDelegate
Version: $Id: SequenceProxyPullConsumerImpl.java,v 1.15 2006/01/12 22:34:54 alphonse.bendt Exp $
UNKNOWN: extends = "AbstractProxyConsumerMBean"
Constructor Summary | |
---|---|
SequenceProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration config, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, SupplierAdmin supplierAdmin) |
Method Summary | |
---|---|
void | connect_sequence_pull_supplier(SequencePullSupplier sequencePullSupplier) |
protected void | disconnectClient() |
void | disconnect_sequence_pull_consumer() |
ProxyType | MyType() |
Servant | newServant() |
MessageSupplierDelegate.PullResult | pullMessages() |
void | queueMessages(PullResult pullResult) |
void | runPullMessage() |