org.jacorb.notification.servant

Class StructuredProxyPullConsumerImpl

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 $

Author: Alphonse Bendt

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
voidconnectionResumed()
protected voidconnectionSuspended()
voidconnect_structured_pull_supplier(StructuredPullSupplier pullSupplier)
protected voiddisconnectClient()
voiddisconnect_structured_pull_consumer()
ProxyTypeMyType()
ServantnewServant()
MessageSupplierDelegate.PullResultpullMessages()
voidqueueMessages(PullResult data)
voidrunPullMessage()
protected voidstartTask()
protected voidstopTask()

Constructor Detail

StructuredProxyPullConsumerImpl

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

Method Detail

connectionResumed

public void connectionResumed()

connectionSuspended

protected void connectionSuspended()

connect_structured_pull_supplier

public void connect_structured_pull_supplier(StructuredPullSupplier pullSupplier)

disconnectClient

protected void disconnectClient()

disconnect_structured_pull_consumer

public void disconnect_structured_pull_consumer()

MyType

public ProxyType MyType()

newServant

public Servant newServant()

pullMessages

public MessageSupplierDelegate.PullResult pullMessages()

queueMessages

public void queueMessages(PullResult data)

runPullMessage

public void runPullMessage()

startTask

protected void startTask()

stopTask

protected void stopTask()