org.jacorb.notification.interfaces
Interface IProxyPushSupplier

All Superinterfaces:
CallbackingDisposable, java.lang.Comparable, org.picocontainer.Disposable, Disposable, MessageConsumer
All Known Implementing Classes:
AbstractProxyPushSupplier

public interface IProxyPushSupplier
extends MessageConsumer, CallbackingDisposable


Method Summary
 void disableDelivery()
          Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead.
 boolean hasPendingData()
          check if this MessageConsumer has pending work to do. pending work is to push events to its connected (Push)Consumer.
 int incErrorCounter()
          increment the current error count by one for this MessageConsumer.
 boolean isRetryAllowed()
           
 void pushPendingData()
          process pending work. push events to its connected (Push)Consumer.
 void resetErrorCounter()
          reset the error counter for this MessageConsumer to zero.
 void schedulePush(PushTaskExecutor.PushTask pushTask)
           
 
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
 

Method Detail

pushPendingData

public void pushPendingData()
process pending work. push events to its connected (Push)Consumer.


hasPendingData

public boolean hasPendingData()
check if this MessageConsumer has pending work to do. pending work is to push events to its connected (Push)Consumer.


disableDelivery

public void disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead.


resetErrorCounter

public void resetErrorCounter()
reset the error counter for this MessageConsumer to zero.


incErrorCounter

public int incErrorCounter()
increment the current error count by one for this MessageConsumer.


isRetryAllowed

public boolean isRetryAllowed()

schedulePush

public void schedulePush(PushTaskExecutor.PushTask pushTask)