|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MessageConsumer
The interface MessageConsumer provides an abstraction of an
ProxySupplier.
The MessageConsumer is responsible
to maintain the Connection to the real Consumer. To deliver a
Message
the MessageConsumer converts the Message to the
appropiate Format (Any, StructuredEvent, Sequence of
StructuredEvent) required by its Consumer and delivers it.
Method Summary | |
---|---|
void |
deliverMessage(Message m)
Deliver a Message to the associated Consumer. |
void |
deliverPendingData()
process pending work. push events to its connected (Push)Consumer. |
void |
disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote operations. events are enqueued instead. |
void |
enableDelivery()
activate deliveries. this MessageConsumer may invoke remote operations again. |
int |
getErrorCounter()
access the current error count for this MessageConsumer. |
int |
getErrorThreshold()
access the error threshold for this MessageConsumer. if the error count exeeds the threshold the MessageConsumer will be disconnected. |
TaskExecutor |
getExecutor()
|
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 |
isDisposed()
check if this MessageConsumer is still valid. |
void |
resetErrorCounter()
reset the error counter for this MessageConsumer to zero. |
Methods inherited from interface org.jacorb.notification.interfaces.Disposable |
---|
dispose |
Method Detail |
---|
TaskExecutor getExecutor()
TaskExecutor
that should be used to
push Messages to the connected Consumer.void deliverPendingData()
boolean hasPendingData()
void enableDelivery()
void disableDelivery()
void deliverMessage(Message m)
void resetErrorCounter()
int getErrorCounter()
int incErrorCounter()
int getErrorThreshold()
boolean isDisposed()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |