org.jacorb.notification.servant

Class StructuredProxyPullConsumerImpl

Implemented Interfaces:
AbstractProxyConsumerI, Configurable, Disposable, FilterAdminOperations, FilterStage, ManageableServant, MessageSupplier, NotifyPublishOperations, ProxyConsumerOperations, QoSAdminOperations, StructuredProxyPullConsumerOperations, StructuredPullConsumerOperations
Known Direct Subclasses:
SequenceProxyPullConsumerImpl

public class StructuredProxyPullConsumerImpl
extends org.jacorb.notification.servant.AbstractProxyConsumer
implements StructuredProxyPullConsumerOperations, MessageSupplier

Version:
$Id: StructuredProxyPullConsumerImpl.java,v 1.9 2004/05/06 12:40:00 nicolas Exp $

Author:
Alphonse Bendt

Field Summary

protected long
pollInterval_
protected Sync
pullSync_

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_

Constructor Summary

StructuredProxyPullConsumerImpl(AbstractAdmin admin, ChannelContext channelContext)

Method Summary

ProxyType
MyType()
Object
activate()
void
configure(Configuration conf)
void
connect_structured_pull_supplier(StructuredPullSupplier pullSupplier)
void
connectionResumed()
protected void
connectionSuspended()
protected void
disconnectClient()
void
disconnect_structured_pull_consumer()
Servant
getServant()
EventType[]
obtain_subscription_types(ObtainInfoMode obtainInfoMode)
protected void
runPullEventInternal()
void
runPullMessage()
the implementation pulls one or more events from its Supplier and hands over the pulled events to the TaskProcessor.
protected void
startTask()
protected void
stopTask()

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

Field Details

pollInterval_

protected long pollInterval_


pullSync_

protected Sync pullSync_

Constructor Details

StructuredProxyPullConsumerImpl

public StructuredProxyPullConsumerImpl(AbstractAdmin admin,
                                       ChannelContext channelContext)

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_structured_pull_supplier

public void connect_structured_pull_supplier(StructuredPullSupplier pullSupplier)
            throws AlreadyConnected
Specified by:
connect_structured_pull_supplier in interface StructuredProxyPullConsumerOperations


connectionResumed

public 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_structured_pull_consumer

public void disconnect_structured_pull_consumer()
Specified by:
disconnect_structured_pull_consumer in interface StructuredPullConsumerOperations


getServant

public Servant getServant()


obtain_subscription_types

public EventType[] obtain_subscription_types(ObtainInfoMode obtainInfoMode)
Specified by:
obtain_subscription_types in interface ProxyConsumerOperations
Overrides:
obtain_subscription_types in interface org.jacorb.notification.servant.AbstractProxyConsumer


runPullEventInternal

protected void runPullEventInternal()
            throws InterruptedException,
                   Disconnected


runPullMessage

public void runPullMessage()
            throws Disconnected
the implementation pulls one or more events from its Supplier and hands over the pulled events to the TaskProcessor.
Specified by:
runPullMessage in interface MessageSupplier


startTask

protected void startTask()


stopTask

protected void stopTask()