org.jacorb.notification.servant
Class SequenceProxyPushSupplierImpl
- Configurable, Disposable, FilterAdminOperations, FilterStage, ManageableServant, MessageConsumer, NotifySubscribeOperations, ProxySupplierOperations, QoSAdminOperations, SequenceProxyPushSupplierOperations, SequencePushSupplierOperations, StructuredProxyPushSupplierOperations, StructuredPushSupplierOperations
public class SequenceProxyPushSupplierImpl
Version:
- Alphonse Bendt
admin_ , channelContext_ , id_ , isIDPublic_ , lifetimeFilter_ , logger_ , offerManager_ , priorityFilter_ , qosSettings_ , subscriptionManager_ , thisServant_ |
MyType , activate , connect_structured_push_consumer , connectionResumed , deliverMessage , deliverPendingData , disconnectClient , disconnect_structured_push_supplier , getMessageConsumer , getServant , getSubsequentFilterStages , hasMessageConsumer |
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 |
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 |
SequenceProxyPushSupplierImpl
public SequenceProxyPushSupplierImpl(AbstractAdmin myAdminServant,
ChannelContext channelContext)
this callback is called by the TimerDaemon. Check if there are
pending Events and deliver them to the Consumer. As there's only one
TimerDaemon its important to
block the daemon only a minimal amount of time. Therefor the Callback
does not do the actual delivery. Instead a
DeliverTask is scheduled for this Supplier.
connectionSuspended
protected void connectionSuspended()
- connectionSuspended in interface AbstractProxy