org.jacorb.notification.servant
Class AbstractProxyPushSupplier
java.lang.Object
org.jacorb.notification.servant.AbstractProxy
org.jacorb.notification.servant.AbstractProxySupplier
org.jacorb.notification.servant.AbstractProxyPushSupplier
- All Implemented Interfaces:
- CallbackingDisposable, java.lang.Comparable, org.apache.avalon.framework.configuration.Configurable, org.picocontainer.Disposable, Disposable, FilterAdminOperations, FilterStage, FilterStageSource, IProxyPushSupplier, ManageableServant, MessageConsumer, NotifySubscribeOperations, QoSAdminOperations
- Direct Known Subclasses:
- ProxyPushSupplierImpl, StructuredProxyPushSupplierImpl, TypedProxyPushSupplierImpl
- public abstract class AbstractProxyPushSupplier
- extends AbstractProxySupplier
- implements IProxyPushSupplier
Methods inherited from class org.jacorb.notification.servant.AbstractProxySupplier |
compareTo, connectClient, deliverMessage, dispose, enqueue, getAllMessages, getAtLeastMessages, getCost, 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, connectionResumed, connectionSuspended, deactivate, destroy, disconnectClient, get_all_filters, get_filter, get_qos, getErrorCounter, getFilters, getID, getLifetimeFilter, getORB, getPOA, getPriorityFilter, getServant, getTaskProcessor, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isConnected, isDisposed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, MyType, 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 |
AbstractProxyPushSupplier
public AbstractProxyPushSupplier(IAdmin admin,
ORB orb,
POA poa,
org.apache.avalon.framework.configuration.Configuration conf,
TaskProcessor taskProcessor,
PushTaskExecutorFactory pushTaskExecutorFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin)
throws org.apache.avalon.framework.configuration.ConfigurationException
handleFailedPushOperation
protected void handleFailedPushOperation(PushOperation operation,
java.lang.Throwable error)
schedulePush
public final void schedulePush()
schedulePush
public final void schedulePush(PushTaskExecutor.PushTask pushTask)
- Specified by:
schedulePush
in interface IProxyPushSupplier
messageDelivered
public final void messageDelivered()
- Description copied from class:
AbstractProxySupplier
- this is an extension point.
- Overrides:
messageDelivered
in class AbstractProxySupplier
resetErrorCounter
public void resetErrorCounter()
- Description copied from interface:
IProxyPushSupplier
- reset the error counter for this MessageConsumer to zero.
- Specified by:
resetErrorCounter
in interface IProxyPushSupplier
- Overrides:
resetErrorCounter
in class AbstractProxy
disableDelivery
public void disableDelivery()
- Description copied from interface:
IProxyPushSupplier
- Disable Deliveries. this MessageConsumer may not invoke remote
operations. events are enqueued instead.
- Specified by:
disableDelivery
in interface IProxyPushSupplier
isEnabled
protected boolean isEnabled()