org.jacorb.notification.servant

Class SequenceProxyPullConsumerImpl

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 $

Author: Alphonse Bendt

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
voidconnect_sequence_pull_supplier(SequencePullSupplier sequencePullSupplier)
protected voiddisconnectClient()
voiddisconnect_sequence_pull_consumer()
ProxyTypeMyType()
ServantnewServant()
MessageSupplierDelegate.PullResultpullMessages()
voidqueueMessages(PullResult pullResult)
voidrunPullMessage()

Constructor Detail

SequenceProxyPullConsumerImpl

public SequenceProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration config, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, SupplierAdmin supplierAdmin)

Method Detail

connect_sequence_pull_supplier

public void connect_sequence_pull_supplier(SequencePullSupplier sequencePullSupplier)

disconnectClient

protected void disconnectClient()

disconnect_sequence_pull_consumer

public void disconnect_sequence_pull_consumer()

MyType

public ProxyType MyType()

newServant

public Servant newServant()

pullMessages

public MessageSupplierDelegate.PullResult pullMessages()

queueMessages

public void queueMessages(PullResult pullResult)

runPullMessage

public void runPullMessage()