org.jacorb.notification

Class EventChannelImpl

Implemented Interfaces:
Configurable, AdminPropertiesAdminOperations, Disposable, EventChannelOperations, EventChannelOperations, InvokeHandler, ManageableServant, QoSAdminOperations

public class EventChannelImpl
extends EventChannelPOA
implements Disposable, ManageableServant, Configurable

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

Author:
Alphonse Bendt

Method Summary

EventChannelFactory
MyFactory()
The MyFactory attribute is a readonly attribute that maintains the object reference of the event channel factory, which created a given Notification Service EventChannel instance.
POA
_default_POA()
Override this method from the Servant baseclass.
Object
activate()
void
addAdminEventListener(AdminEventListener l)
void
configure(Configuration conf)
void
deactivate()
ConsumerAdmin
default_consumer_admin()
The default_consumer_admin attribute is a readonly attribute that maintains a reference to the default ConsumerAdmin instance associated with the target EventChannel instance.
FilterFactory
default_filter_factory()
The default_filter_factory attribute is a readonly attribute that maintains an object reference to the default factory to be used by the EventChannel instance with which it is associated for creating filter objects.
SupplierAdmin
default_supplier_admin()
The default_supplier_admin attribute is a readonly attribute that maintains a reference to the default SupplierAdmin instance associated with the target EventChannel instance.
void
destroy()
destroy this Channel, all created Admins and all Proxies.
void
dispose()
ConsumerAdmin
for_consumers()
Return the consumerAdmin interface (event style)
SupplierAdmin
for_suppliers()
Return the supplierAdmin interface (event style)
List
getAllConsumerAdmins()
fetch the List of all ConsumerAdmins that are connected to this EventChannel.
ChannelContext
getChannelContext()
String
getIOR()
int
getKey()
int
getMaxNumberOfConsumers()
int
getMaxNumberOfSuppliers()
int
getNumberOfConnectedClients()
get the number of clients connected to this event channel. the number is the total of all Suppliers and Consumers connected to this channel.
Servant
getServant()
Property[]
get_admin()
int[]
get_all_consumeradmins()
int[]
get_all_supplieradmins()
ConsumerAdmin
get_consumeradmin(int identifier)
Property[]
get_qos()
SupplierAdmin
get_supplieradmin(int identifier)
boolean
isPersistent()
ConsumerAdmin
new_for_consumers(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
The new_for_consumers operation is invoked to create a new Notification Service style ConsumerAdmin instance.
SupplierAdmin
new_for_suppliers(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
void
preActivate()
void
removeAdminEventListener(AdminEventListener l)
void
setKey(int key)
void
setORB(ORB orb)
void
setPOA(POA poa)
void
set_admin(Property adminProps)
void
set_qos(Property props)
void
validate_qos(Property props, NamedPropertyRangeSeqHolder namedPropertySeqHolder)

Methods inherited from class org.omg.CosNotifyChannelAdmin.EventChannelPOA

_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

Method Details

MyFactory

public EventChannelFactory MyFactory()
The MyFactory attribute is a readonly attribute that maintains the object reference of the event channel factory, which created a given Notification Service EventChannel instance.
Specified by:
MyFactory in interface EventChannelOperations


_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


activate

public Object activate()
Specified by:
activate in interface ManageableServant


addAdminEventListener

public void addAdminEventListener(AdminEventListener l)


configure

public void configure(Configuration conf)
            throws ConfigurationException


deactivate

public void deactivate()
Specified by:
deactivate in interface ManageableServant


default_consumer_admin

public ConsumerAdmin default_consumer_admin()
The default_consumer_admin attribute is a readonly attribute that maintains a reference to the default ConsumerAdmin instance associated with the target EventChannel instance. Each EventChannel instance has an associated default ConsumerAdmin instance, which exists upon creation of the channel and is assigned the unique identifier of zero. Subsequently, clients can create additional Event Service style ConsumerAdmin instances by invoking the inherited operation, and additional Notification Service style ConsumerAdmin instances by invoking the new_for_consumers operation defined by the EventChannel interface.
Specified by:
default_consumer_admin in interface EventChannelOperations


default_filter_factory

public FilterFactory default_filter_factory()
The default_filter_factory attribute is a readonly attribute that maintains an object reference to the default factory to be used by the EventChannel instance with which it is associated for creating filter objects. If the target channel does not support a default filter factory, the attribute will maintain the value of OBJECT_NIL.
Specified by:
default_filter_factory in interface EventChannelOperations


default_supplier_admin

public SupplierAdmin default_supplier_admin()
The default_supplier_admin attribute is a readonly attribute that maintains a reference to the default SupplierAdmin instance associated with the target EventChannel instance. Each EventChannel instance has an associated default SupplierAdmin instance, which exists upon creation of the channel and is assigned the unique identifier of zero. Subsequently, clients can create additional Event Service style SupplierAdmin instances by invoking the inherited for_suppliers operation, and additional Notification Service style SupplierAdmin instances by invoking the new_for_suppliers operation defined by the EventChannel interface.
Specified by:
default_supplier_admin in interface EventChannelOperations


destroy

public void destroy()
destroy this Channel, all created Admins and all Proxies.
Specified by:
destroy in interface EventChannelOperations


dispose

public void dispose()
Specified by:
dispose in interface Disposable


for_consumers

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


for_suppliers

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


getAllConsumerAdmins

public List getAllConsumerAdmins()
fetch the List of all ConsumerAdmins that are connected to this EventChannel.


getChannelContext

public ChannelContext getChannelContext()


getIOR

public String getIOR()


getKey

public int getKey()


getMaxNumberOfConsumers

public int getMaxNumberOfConsumers()


getMaxNumberOfSuppliers

public int getMaxNumberOfSuppliers()


getNumberOfConnectedClients

public int getNumberOfConnectedClients()
get the number of clients connected to this event channel. the number is the total of all Suppliers and Consumers connected to this channel.


getServant

public Servant getServant()


get_admin

public Property[] get_admin()
Specified by:
get_admin in interface AdminPropertiesAdminOperations


get_all_consumeradmins

public int[] get_all_consumeradmins()
Specified by:
get_all_consumeradmins in interface EventChannelOperations


get_all_supplieradmins

public int[] get_all_supplieradmins()
Specified by:
get_all_supplieradmins in interface EventChannelOperations


get_consumeradmin

public ConsumerAdmin get_consumeradmin(int identifier)
            throws AdminNotFound
Specified by:
get_consumeradmin in interface EventChannelOperations


get_qos

public Property[] get_qos()
Specified by:
get_qos in interface QoSAdminOperations


get_supplieradmin

public SupplierAdmin get_supplieradmin(int identifier)
            throws AdminNotFound
Specified by:
get_supplieradmin in interface EventChannelOperations


isPersistent

public boolean isPersistent()


new_for_consumers

public ConsumerAdmin new_for_consumers(InterFilterGroupOperator filterGroupOperator,
                                       IntHolder intHolder)
The new_for_consumers operation is invoked to create a new Notification Service style ConsumerAdmin instance. The operation accepts as an input parameter a boolean flag, which indicates whether AND or OR semantics will be used when combining the filter objects associated with the newly created ConsumerAdmin instance with those associated with a supplier proxy, which was created by the ConsumerAdmin during the evaluation of each event against a set of filter objects. The new instance is assigned a unique identifier by the target EventChannel instance that is unique among all ConsumerAdmin instances currently associated with the channel. Upon completion, the operation returns the reference to the new ConsumerAdmin instance as the result of the operation, and the unique identifier assigned to the new ConsumerAdmin instance as the output parameter.
Specified by:
new_for_consumers in interface EventChannelOperations


new_for_suppliers

public SupplierAdmin new_for_suppliers(InterFilterGroupOperator filterGroupOperator,
                                       IntHolder intHolder)
Specified by:
new_for_suppliers in interface EventChannelOperations


preActivate

public void preActivate()
Specified by:
preActivate in interface ManageableServant


removeAdminEventListener

public void removeAdminEventListener(AdminEventListener l)


setKey

public void setKey(int key)


setORB

public void setORB(ORB orb)
Specified by:
setORB in interface ManageableServant


setPOA

public void setPOA(POA poa)
Specified by:
setPOA in interface ManageableServant


set_admin

public void set_admin(Property adminProps)
            throws UnsupportedAdmin


set_qos

public void set_qos(Property props)
            throws UnsupportedQoS


validate_qos

public void validate_qos(Property props,
                         NamedPropertyRangeSeqHolder namedPropertySeqHolder)
            throws UnsupportedQoS