org.jacorb.notification.servant
Class SequenceProxyPushSupplierImpl
java.lang.Object
org.jacorb.notification.servant.AbstractProxy
org.jacorb.notification.servant.AbstractProxySupplier
org.jacorb.notification.servant.AbstractProxyPushSupplier
org.jacorb.notification.servant.StructuredProxyPushSupplierImpl
org.jacorb.notification.servant.SequenceProxyPushSupplierImpl
- All Implemented Interfaces:
- CallbackingDisposable, java.lang.Comparable, org.apache.avalon.framework.configuration.Configurable, org.picocontainer.Disposable, Disposable, FilterAdminOperations, FilterStage, FilterStageSource, IProxyPushSupplier, ManageableServant, MessageConsumer, NotifySubscribeOperations, ProxySupplierOperations, QoSAdminOperations, SequenceProxyPushSupplierOperations, SequencePushSupplierOperations, StructuredProxyPushSupplierOperations, StructuredPushSupplierOperations
- public class SequenceProxyPushSupplierImpl
- extends StructuredProxyPushSupplierImpl
- implements SequenceProxyPushSupplierOperations
- Version:
- $Id: SequenceProxyPushSupplierImpl.java,v 1.17 2005/04/27 10:45:46 alphonse.bendt Exp $
- Author:
- Alphonse Bendt
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier |
compareTo, connectClient, deliverMessage, dispose, enqueue, getAllMessages, getAtLeastMessages, getErrorThreshold, getMessageBlocking, getMessageNoBlock, getMessageQueueFactory, getPendingMessagesCount, getUpToMessages, hasMessageConsumer, hasPendingData, isRetryAllowed, MyAdmin, obtain_offered_types, removeListener, subscription_change |
Methods inherited from class org.jacorb.notification.servant.AbstractProxy |
_default_POA, add_filter, addDisposeHook, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, deactivate, destroy, get_all_filters, get_filter, get_qos, getErrorCounter, getFilters, getID, getLifetimeFilter, getORB, getPOA, getPriorityFilter, getTaskProcessor, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isConnected, isDisposed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, priority_filter, priority_filter, remove_all_filters, remove_filter, resume_connection, set_qos, suspend_connection, validate_event_qos, validate_qos |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface java.lang.Comparable |
compareTo |
Methods inherited from interface org.picocontainer.Disposable |
dispose |
SequenceProxyPushSupplierImpl
public SequenceProxyPushSupplierImpl(IAdmin admin,
ORB orb,
POA poa,
org.apache.avalon.framework.configuration.Configuration config,
TaskProcessor taskProcessor,
PushTaskExecutorFactory pushTaskExecutorFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin)
throws org.apache.avalon.framework.configuration.ConfigurationException
MyType
public ProxyType MyType()
- 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.
- Specified by:
MyType
in interface ProxySupplierOperations
- Overrides:
MyType
in class StructuredProxyPushSupplierImpl
pushPendingData
public void pushPendingData()
- overrides the superclass version.
- Specified by:
pushPendingData
in interface IProxyPushSupplier
- Overrides:
pushPendingData
in class StructuredProxyPushSupplierImpl
connect_sequence_push_consumer
public void connect_sequence_push_consumer(SequencePushConsumer consumer)
throws AlreadyConnected,
TypeError
- Specified by:
connect_sequence_push_consumer
in interface SequenceProxyPushSupplierOperations
- Throws:
AlreadyConnected
TypeError
connectionResumed
protected void connectionResumed()
- Description copied from class:
AbstractProxy
- this is an extension point.
invoked when resume_connection was called successfully.
- Overrides:
connectionResumed
in class StructuredProxyPushSupplierImpl
connectionSuspended
protected void connectionSuspended()
- Description copied from class:
AbstractProxy
- this is an extension point.
- Overrides:
connectionSuspended
in class AbstractProxy
disconnect_sequence_push_supplier
public void disconnect_sequence_push_supplier()
- Specified by:
disconnect_sequence_push_supplier
in interface SequencePushSupplierOperations
disconnectClient
protected void disconnectClient()
- Description copied from class:
AbstractProxy
- invoke the proxy specific disconnect method.
- Overrides:
disconnectClient
in class StructuredProxyPushSupplierImpl
getServant
public Servant getServant()
- Overrides:
getServant
in class StructuredProxyPushSupplierImpl
getCost
protected long getCost()
- Overrides:
getCost
in class StructuredProxyPushSupplierImpl