TAO_RTEvent
2.1.8
|
Interface used to implement the Abstract Session pattern for the consumers. More...
import "RtecEventChannelAdmin.idl";
Public Member Functions | |
void | connect_push_consumer (in RtecEventComm::PushConsumer push_consumer, in ConsumerQOS qos) raises (AlreadyConnected, TypeError) |
Connect a consumer with the Event Channel. More... | |
void | suspend_connection () |
void | resume_connection () |
Resume the reception of events. More... | |
![]() | |
void | disconnect_push_supplier () |
Callback method to indicate a disconnection. More... | |
Interface used to implement the Abstract Session pattern for the consumers.
Each consumer converse with the Event Channel via a different object that implements the ProxyPushSupplier interface. This is a common idiom in CORBA, as it allows the identification of the remove consumer efficiently.
void RtecEventChannelAdmin::ProxyPushSupplier::connect_push_consumer | ( | in RtecEventComm::PushConsumer | push_consumer, |
in ConsumerQOS | qos | ||
) | raises (AlreadyConnected, TypeError) |
Connect a consumer with the Event Channel.
The ConsumerQOS argument is used to setup the filtering and QoS properties of the consumer.
push_consumer | The consumer that will receive the events. |
qos | The QoS properties for this consumer |
CORBA::BAD_PARAM | if push_consumer is nil |
AlreadyConnected | if this operation is invoked multiple times |
void RtecEventChannelAdmin::ProxyPushSupplier::resume_connection | ( | ) |
Resume the reception of events.
void RtecEventChannelAdmin::ProxyPushSupplier::suspend_connection | ( | ) |
Temporarily suspend reception of events from the Event Channel. Calling this method is more efficient than dropping the events when received by the consumer, and less expensive than disconnecting and connecting again (but it is not free!!)