org.jacorb.notification.servant

Class StructuredProxyPullSupplierImpl

Implemented Interfaces:
Configurable, Disposable, FilterAdminOperations, FilterStage, ManageableServant, MessageConsumer, NotifySubscribeOperations, ProxySupplierOperations, QoSAdminOperations, StructuredProxyPullSupplierOperations, StructuredPullSupplierOperations
Known Direct Subclasses:
SequenceProxyPullSupplierImpl

public class StructuredProxyPullSupplierImpl
extends AbstractProxySupplier
implements StructuredProxyPullSupplierOperations

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

Author:
Alphonse Bendt

Field Summary

protected static StructuredEvent
undefinedStructuredEvent_
undefined StructuredEvent that is returned on unsuccessful pull operations.

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

scheduleDeliverPendingMessagesOperation_

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

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

Constructor Summary

StructuredProxyPullSupplierImpl(AbstractAdmin myAdminServant, ChannelContext channelContext)

Method Summary

ProxyType
MyType()
Object
activate()
void
connect_structured_pull_consumer(StructuredPullConsumer consumer)
void
deliverMessage(Message event)
PullSupplier always enqueues.
void
deliverPendingData()
process pending work. push events to its connected (Push)Consumer.
void
disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead.
protected void
disconnectClient()
void
disconnect_structured_pull_supplier()
void
enableDelivery()
activate deliveries. this MessageConsumer may invoke remote operations again.
MessageConsumer
getMessageConsumer()
Servant
getServant()
List
getSubsequentFilterStages()
boolean
hasMessageConsumer()
StructuredEvent
pull_structured_event()
StructuredEvent
try_pull_structured_event(BooleanHolder hasEvent)

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

MyAdmin, configure, connectClient, disableDelivery, dispose, enableDelivery, enqueue, getAllMessages, getAtLeastMessages, getErrorThreshold, getExecutor, getMessageBlocking, getMessageNoBlock, getPendingMessagesCount, getUpToMessages, handleFailedPushOperation, hasPendingData, isEnabled, isPushSupplier, obtain_offered_types, preActivate, setTaskExecutor, setTaskExecutor, subscription_change

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

undefinedStructuredEvent_

protected static final StructuredEvent undefinedStructuredEvent_
undefined StructuredEvent that is returned on unsuccessful pull operations.

Constructor Details

StructuredProxyPullSupplierImpl

public StructuredProxyPullSupplierImpl(AbstractAdmin myAdminServant,
                                       ChannelContext channelContext)

Method Details

MyType

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


activate

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


connect_structured_pull_consumer

public void connect_structured_pull_consumer(StructuredPullConsumer consumer)
            throws AlreadyConnected
Specified by:
connect_structured_pull_consumer in interface StructuredProxyPullSupplierOperations


deliverMessage

public void deliverMessage(Message event)
PullSupplier always enqueues.
Specified by:
deliverMessage in interface MessageConsumer


deliverPendingData

public void deliverPendingData()
process pending work. push events to its connected (Push)Consumer.
Specified by:
deliverPendingData in interface MessageConsumer


disableDelivery

public void disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead.
Specified by:
disableDelivery in interface MessageConsumer
Overrides:
disableDelivery in interface AbstractProxySupplier


disconnectClient

protected void disconnectClient()
Overrides:
disconnectClient in interface AbstractProxy


disconnect_structured_pull_supplier

public void disconnect_structured_pull_supplier()
Specified by:
disconnect_structured_pull_supplier in interface StructuredPullSupplierOperations


enableDelivery

public void enableDelivery()
activate deliveries. this MessageConsumer may invoke remote operations again.
Specified by:
enableDelivery in interface MessageConsumer
Overrides:
enableDelivery in interface AbstractProxySupplier


getMessageConsumer

public MessageConsumer getMessageConsumer()
Specified by:
getMessageConsumer in interface FilterStage


getServant

public Servant getServant()


getSubsequentFilterStages

public List getSubsequentFilterStages()
Specified by:
getSubsequentFilterStages in interface FilterStage


hasMessageConsumer

public boolean hasMessageConsumer()
Specified by:
hasMessageConsumer in interface FilterStage


pull_structured_event

public StructuredEvent pull_structured_event()
            throws Disconnected
Specified by:
pull_structured_event in interface StructuredPullSupplierOperations


try_pull_structured_event

public StructuredEvent try_pull_structured_event(BooleanHolder hasEvent)
            throws Disconnected
Specified by:
try_pull_structured_event in interface StructuredPullSupplierOperations