org.jacorb.notification.interfaces
Interface MessageConsumer
- Disposable
- AbstractProxySupplier, ECProxyPullSupplierImpl, ECProxyPushSupplierImpl, ProxyPullSupplierImpl, ProxyPushSupplierImpl, SequenceProxyPullSupplierImpl, SequenceProxyPushSupplierImpl, StructuredProxyPullSupplierImpl, StructuredProxyPushSupplierImpl
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.
Version:
- Alphonse Bendt
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.
|
deliverMessage
public void deliverMessage(Message m)
Deliver a Message to the associated Consumer.
deliverPendingData
public void deliverPendingData()
process pending work. push events to its connected
(Push)Consumer.
disableDelivery
public void disableDelivery()
Disable Deliveries. this MessageConsumer may not invoke remote
operations. events are enqueued instead.
enableDelivery
public void enableDelivery()
activate deliveries. this MessageConsumer may invoke remote
operations again.
getErrorCounter
public int getErrorCounter()
access the current error count for this MessageConsumer.
getErrorThreshold
public int getErrorThreshold()
access the error threshold for this MessageConsumer. if the
error count exeeds the threshold the MessageConsumer will be
disconnected.
getExecutor
public TaskExecutor getExecutor()
- the
TaskExecutor
that should be used to
push Messages to the connected 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.
incErrorCounter
public int incErrorCounter()
increment the current error count by one for this MessageConsumer.
isDisposed
public boolean isDisposed()
check if this MessageConsumer is still valid.
resetErrorCounter
public void resetErrorCounter()
reset the error counter for this MessageConsumer to zero.