org.jacorb.events

Class EventChannelImpl

Implemented Interfaces:
ConsumerAdminOperations, EventChannelOperations, InvokeHandler, JacORBEventChannelOperations, SupplierAdminOperations

public class EventChannelImpl
extends JacORBEventChannelPOA

Simple implementation of the event channel spec. The event channel acts as a factory for proxy push/pull consumers/suppliers and interacts with the implementation objects locally, i.e. using Java references only.

Version:
$Id: EventChannelImpl.java,v 1.10 2004/05/06 12:39:58 nicolas Exp $

Author:
Joerg v. Frantzius, Rainer Lischetzki, Gerald Brose, Jeff Carlson

Constructor Summary

EventChannelImpl(ORB orb, POA poa)
EventChannel constructor.

Method Summary

POA
_default_POA()
Override this method from the Servant baseclass.
void
destroy()
Destroy all objects which are managed by the POA.
ConsumerAdmin
for_consumers()
Return the consumerAdmin interface
SupplierAdmin
for_suppliers()
Return the supplierAdmin interface
static void
main(String[] args)
ProxyPullConsumer
obtain_pull_consumer()
Return a ProxyPullConsumer reference to be used to connect to a PullSupplier.
ProxyPullSupplier
obtain_pull_supplier()
Return a ProxyPullSupplier reference to be used to connect to a PullConsumer.
ProxyPushConsumer
obtain_push_consumer()
Return a ProxyPushConsumer reference to be used to connect to a PushSupplier.
ProxyPushSupplier
obtain_push_supplier()
Return a ProxyPushSupplier reference to be used to connect to a PushConsumer.
protected void
push_event(Any event)
Send event to all registered consumers.

Methods inherited from class org.jacorb.events.JacORBEventChannelPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_all_interfaces, _default_POA, _get_delegate, _get_interface, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

Constructor Details

EventChannelImpl

public EventChannelImpl(ORB orb,
                        POA poa)
EventChannel constructor.

Method Details

_default_POA

public POA _default_POA()
Override this method from the Servant baseclass. Fintan Bolton in his book "Pure CORBA" suggests that you override this method to avoid the risk that a servant object (like this one) could be activated by the wrong POA object.
Overrides:
_default_POA in interface Servant


destroy

public void destroy()
Destroy all objects which are managed by the POA.
Specified by:
destroy in interface EventChannelOperations


for_consumers

public ConsumerAdmin for_consumers()
Return the consumerAdmin interface
Specified by:
for_consumers in interface EventChannelOperations


for_suppliers

public SupplierAdmin for_suppliers()
Return the supplierAdmin interface
Specified by:
for_suppliers in interface EventChannelOperations


main

public static void main(String[] args)


obtain_pull_consumer

public ProxyPullConsumer obtain_pull_consumer()
Return a ProxyPullConsumer reference to be used to connect to a PullSupplier.
Specified by:
obtain_pull_consumer in interface SupplierAdminOperations


obtain_pull_supplier

public ProxyPullSupplier obtain_pull_supplier()
Return a ProxyPullSupplier reference to be used to connect to a PullConsumer.
Specified by:
obtain_pull_supplier in interface ConsumerAdminOperations


obtain_push_consumer

public ProxyPushConsumer obtain_push_consumer()
Return a ProxyPushConsumer reference to be used to connect to a PushSupplier.
Specified by:
obtain_push_consumer in interface SupplierAdminOperations


obtain_push_supplier

public ProxyPushSupplier obtain_push_supplier()
Return a ProxyPushSupplier reference to be used to connect to a PushConsumer.
Specified by:
obtain_push_supplier in interface ConsumerAdminOperations


push_event

protected void push_event(Any event)
Send event to all registered consumers.