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)