org.jacorb.notification.servant
Class AbstractProxyPushSupplier

java.lang.Object
  extended byorg.jacorb.notification.servant.AbstractProxy
      extended byorg.jacorb.notification.servant.AbstractProxySupplier
          extended byorg.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


Field Summary
 
Fields inherited from class org.jacorb.notification.servant.AbstractProxy
id_, isIDPublic_, lifetimeFilter_, logger_, offerManager_, priorityFilter_, qosSettings_, subscriptionManager_, thisServant_
 
Constructor Summary
AbstractProxyPushSupplier(IAdmin admin, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration conf, TaskProcessor taskProcessor, PushTaskExecutorFactory pushTaskExecutorFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin)
           
 
Method Summary
 void disableDelivery()
          Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead.
protected  void handleFailedPushOperation(PushOperation operation, java.lang.Throwable error)
           
protected  boolean isEnabled()
           
 void messageDelivered()
          this is an extension point.
 void resetErrorCounter()
          reset the error counter for this MessageConsumer to zero.
 void schedulePush()
           
 void schedulePush(PushTaskExecutor.PushTask pushTask)
           
 
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 org.jacorb.notification.interfaces.IProxyPushSupplier
hasPendingData, incErrorCounter, isRetryAllowed, pushPendingData
 
Methods inherited from interface org.jacorb.notification.interfaces.MessageConsumer
deliverMessage, destroy, isDisposed
 
Methods inherited from interface java.lang.Comparable
compareTo
 
Methods inherited from interface org.jacorb.notification.interfaces.CallbackingDisposable
addDisposeHook
 
Methods inherited from interface org.picocontainer.Disposable
dispose
 
Methods inherited from interface org.jacorb.notification.interfaces.FilterStage
getMessageConsumer
 
Methods inherited from interface org.jacorb.notification.interfaces.FilterStageSource
getSubsequentFilterStages
 
Methods inherited from interface org.jacorb.notification.servant.ManageableServant
activate
 

Constructor Detail

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
Method Detail

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()