|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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 |
public void pushPendingData()
public boolean hasPendingData()
public void disableDelivery()
public void resetErrorCounter()
public int incErrorCounter()
public boolean isRetryAllowed()
public void schedulePush(PushTaskExecutor.PushTask pushTask)
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |