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

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

Method Detail

public void connect_sequence_pull_supplier(SequencePullSupplier sequencePullSupplier)

protected void disconnectClient()

public void disconnect_sequence_pull_consumer()

public ProxyType MyType()

public Servant newServant()

public void queueMessages(PullResult pullResult)

public void runPullMessage()