org.jacorb.notification.servant

Class ProxyPullConsumerImpl

Implemented Interfaces:
AbstractProxyConsumerI, Configurable, Disposable, FilterAdminOperations, FilterStage, ManageableServant, MessageSupplier, NotifyPublishOperations, ProxyConsumerOperations, ProxyPullConsumerOperations, PullConsumerOperations, PullConsumerOperations, QoSAdminOperations
Known Direct Subclasses:
ECProxyPullConsumerImpl

public class ProxyPullConsumerImpl
extends org.jacorb.notification.servant.AbstractProxyConsumer
implements ProxyPullConsumerOperations, MessageSupplier

Version:
$Id: ProxyPullConsumerImpl.java,v 1.8 2004/05/06 12:39:59 nicolas Exp $

Author:
Alphonse Bendt

Field Summary

Fields inherited from class org.jacorb.notification.servant.AbstractProxyConsumer

messageFactory_

Fields inherited from class org.jacorb.notification.servant.AbstractProxy

admin_, channelContext_, id_, isIDPublic_, lifetimeFilter_, logger_, offerManager_, priorityFilter_, qosSettings_, subscriptionManager_, thisServant_

Method Summary

ProxyType
MyType()
Object
activate()
void
configure(Configuration conf)
void
connect_any_pull_supplier(PullSupplier pullSupplier)
protected void
connectionResumed()
protected void
connectionSuspended()
protected void
disconnectClient()
void
disconnect_pull_consumer()
long
getPollInterval()
int
getPullCounter()
long
getPullTimer()
Servant
getServant()
int
getSuccessfulPullCounter()
void
runPullMessage()

Methods inherited from class org.jacorb.notification.servant.AbstractProxyConsumer

MyAdmin, checkMessageProperties, connectClient, getFirstStage, getMessageConsumer, getSubsequentFilterStages, hasMessageConsumer, isStartTimeSupported, isTimeOutSupported, obtain_subscription_types, offer_change, preActivate, schedulePullTask

Methods inherited from class org.jacorb.notification.servant.AbstractProxy

MyType, _default_POA, add_filter, assertConnected, assertNotConnected, checkStillConnected, configure, connectClient, connectionResumed, connectionSuspended, deactivate, disconnectClient, dispose, getErrorCounter, getFilters, getID, getLifetimeFilter, getORB, getPOA, getPriorityFilter, getTaskProcessor, get_all_filters, get_filter, get_qos, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isConnected, isDisposed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, preActivate, priority_filter, priority_filter, remove_all_filters, remove_filter, resetErrorCounter, resume_connection, setDisposeHook, setID, setORB, setOfferManager, setPOA, setSubscriptionManager, setTaskProcessor, set_qos, suspend_connection, validate_event_qos, validate_qos

Method Details

MyType

public ProxyType MyType()
Specified by:
MyType in interface ProxyConsumerOperations
Overrides:
MyType in interface AbstractProxy


activate

public Object activate()
Specified by:
activate in interface ManageableServant


configure

public void configure(Configuration conf)
Overrides:
configure in interface AbstractProxy


connect_any_pull_supplier

public void connect_any_pull_supplier(PullSupplier pullSupplier)
            throws AlreadyConnected
Specified by:
connect_any_pull_supplier in interface ProxyPullConsumerOperations


connectionResumed

protected void connectionResumed()
Overrides:
connectionResumed in interface AbstractProxy


connectionSuspended

protected void connectionSuspended()
Overrides:
connectionSuspended in interface AbstractProxy


disconnectClient

protected void disconnectClient()
Overrides:
disconnectClient in interface AbstractProxy


disconnect_pull_consumer

public void disconnect_pull_consumer()
Specified by:
disconnect_pull_consumer in interface PullConsumerOperations


getPollInterval

public long getPollInterval()


getPullCounter

public int getPullCounter()


getPullTimer

public long getPullTimer()


getServant

public Servant getServant()


getSuccessfulPullCounter

public int getSuccessfulPullCounter()


runPullMessage

public void runPullMessage()
            throws Disconnected
Specified by:
runPullMessage in interface MessageSupplier