org.jacorb.notification.servant

Class ProxyPullConsumerImpl

public class ProxyPullConsumerImpl extends AbstractProxyConsumer implements ProxyPullConsumerOperations, MessageSupplier, MessageSupplierDelegate, ProxyPullConsumerImplMBean

Version: $Id: ProxyPullConsumerImpl.java,v 1.16 2006/01/12 22:34:54 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN: extends = "AbstractProxyConsumerMBean"

Constructor Summary
ProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
Method Summary
protected voidconnectionResumed()
protected voidconnectionSuspended()
voidconnect_any_pull_supplier(PullSupplier pullSupplier)
protected voiddisconnectClient()
voiddisconnect_pull_consumer()
longgetPollInterval()
intgetPullCounter()
longgetPullTimer()
intgetSuccessfulPullCounter()
ProxyTypeMyType()
ServantnewServant()
MessageSupplierDelegate.PullResultpullMessages()
voidqueueMessages(PullResult data)
voidrunPullMessage()

Constructor Detail

ProxyPullConsumerImpl

public ProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)

Method Detail

connectionResumed

protected void connectionResumed()

connectionSuspended

protected void connectionSuspended()

connect_any_pull_supplier

public void connect_any_pull_supplier(PullSupplier pullSupplier)

disconnectClient

protected void disconnectClient()

disconnect_pull_consumer

public void disconnect_pull_consumer()

getPollInterval

public long getPollInterval()

getPullCounter

public int getPullCounter()

getPullTimer

public long getPullTimer()

getSuccessfulPullCounter

public int getSuccessfulPullCounter()

MyType

public ProxyType MyType()

newServant

public Servant newServant()

pullMessages

public MessageSupplierDelegate.PullResult pullMessages()

queueMessages

public void queueMessages(PullResult data)

runPullMessage

public void runPullMessage()