org.jacorb.events
Class EventChannelImpl

java.lang.Object
  extended byorg.omg.PortableServer.Servant
      extended byorg.jacorb.events.JacORBEventChannelPOA
          extended byorg.jacorb.events.EventChannelImpl
All 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(java.lang.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
_get_delegate, _get_interface_def, _get_interface, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

EventChannelImpl

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

Method Detail

destroy

public void destroy()
Destroy all objects which are managed by the POA.


for_consumers

public ConsumerAdmin for_consumers()
Return the consumerAdmin interface


for_suppliers

public SupplierAdmin for_suppliers()
Return the supplierAdmin interface


obtain_pull_consumer

public ProxyPullConsumer obtain_pull_consumer()
Return a ProxyPullConsumer reference to be used to connect to a PullSupplier.


obtain_pull_supplier

public ProxyPullSupplier obtain_pull_supplier()
Return a ProxyPullSupplier reference to be used to connect to a PullConsumer.


obtain_push_consumer

public ProxyPushConsumer obtain_push_consumer()
Return a ProxyPushConsumer reference to be used to connect to a PushSupplier.


obtain_push_supplier

public ProxyPushSupplier obtain_push_supplier()
Return a ProxyPushSupplier reference to be used to connect to a PushConsumer.


push_event

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


main

public static void main(java.lang.String[] args)

_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 class Servant