org.jacorb.notification
Class AbstractEventChannel

java.lang.Object
  extended byorg.jacorb.notification.AbstractEventChannel
All Implemented Interfaces:
org.picocontainer.Disposable, Disposable, ManageableServant
Direct Known Subclasses:
EventChannelImpl, TypedEventChannelImpl

public abstract class AbstractEventChannel
extends java.lang.Object
implements Disposable, ManageableServant

Version:
$Id: AbstractEventChannel.java,v 1.5 2005/04/27 10:32:06 alphonse.bendt Exp $
Author:
Alphonse Bendt

Field Summary
protected  org.apache.avalon.framework.configuration.Configuration configuration_
           
protected  org.picocontainer.MutablePicoContainer container_
           
protected  boolean duringConstruction_
           
protected  org.apache.avalon.framework.logger.Logger logger_
           
protected  ORB orb_
           
protected  POA poa_
           
 
Constructor Summary
AbstractEventChannel(IFactory factory, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration config, FilterFactory filterFactory)
           
 
Method Summary
 POA _default_POA()
          Override this method from the Servant baseclass.
 void addDisposeHook(Disposable d)
           
 void deactivate()
           
 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.
 void destroy()
          destroy this Channel, all created Admins and all Proxies.
 void dispose()
           
 Property[] get_admin()
           
 int[] get_all_consumeradmins()
           
 int[] get_all_supplieradmins()
           
protected  AbstractAdmin get_consumeradmin_internal(int identifier)
           
 Property[] get_qos()
           
protected  AbstractAdmin get_supplieradmin_internal(int identifier)
           
 int getAdminID()
           
protected  AbstractAdmin getDefaultConsumerAdminServant()
           
protected  AbstractAdmin getDefaultSupplierAdminServant()
           
 int getID()
           
 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.
protected abstract  Servant getServant()
           
protected  boolean isDefaultConsumerAdminActive()
           
protected  boolean isDefaultSupplierAdminActive()
           
 boolean isPersistent()
           
protected  AbstractAdmin new_for_consumers_servant(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
           
protected  AbstractAdmin new_for_suppliers_servant(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
           
protected abstract  AbstractAdmin newConsumerAdmin(int id)
           
protected abstract  AbstractSupplierAdmin newSupplierAdmin(int id)
           
 void set_admin(Property[] adminProps)
           
 void set_qos(Property[] props)
           
 void validate_qos(Property[] props, NamedPropertyRangeSeqHolder namedPropertySeqHolder)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.jacorb.notification.servant.ManageableServant
activate
 

Field Detail

logger_

protected final org.apache.avalon.framework.logger.Logger logger_

orb_

protected final ORB orb_

poa_

protected final POA poa_

configuration_

protected final org.apache.avalon.framework.configuration.Configuration configuration_

duringConstruction_

protected boolean duringConstruction_

container_

protected final org.picocontainer.MutablePicoContainer container_
Constructor Detail

AbstractEventChannel

public AbstractEventChannel(IFactory factory,
                            ORB orb,
                            POA poa,
                            org.apache.avalon.framework.configuration.Configuration config,
                            FilterFactory filterFactory)
Method Detail

getAdminID

public final int getAdminID()

isDefaultConsumerAdminActive

protected final boolean isDefaultConsumerAdminActive()

isDefaultSupplierAdminActive

protected final boolean isDefaultSupplierAdminActive()

default_filter_factory

public final 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.


get_all_consumeradmins

public final int[] get_all_consumeradmins()

get_all_supplieradmins

public final int[] get_all_supplieradmins()

get_admin

public final Property[] get_admin()

get_qos

public final Property[] get_qos()

set_qos

public final void set_qos(Property[] props)
                   throws UnsupportedQoS
Throws:
UnsupportedQoS

validate_qos

public final void validate_qos(Property[] props,
                               NamedPropertyRangeSeqHolder namedPropertySeqHolder)
                        throws UnsupportedQoS
Throws:
UnsupportedQoS

set_admin

public final void set_admin(Property[] adminProps)
                     throws UnsupportedAdmin
Throws:
UnsupportedAdmin

destroy

public final void destroy()
destroy this Channel, all created Admins and all Proxies.


dispose

public final void dispose()
Specified by:
dispose in interface org.picocontainer.Disposable

_default_POA

public final 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.


isPersistent

public boolean isPersistent()

getNumberOfConnectedClients

public final 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.


getMaxNumberOfSuppliers

public final int getMaxNumberOfSuppliers()

getMaxNumberOfConsumers

public final int getMaxNumberOfConsumers()

deactivate

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

getServant

protected abstract Servant getServant()

get_consumeradmin_internal

protected AbstractAdmin get_consumeradmin_internal(int identifier)
                                            throws AdminNotFound
Throws:
AdminNotFound

get_supplieradmin_internal

protected AbstractAdmin get_supplieradmin_internal(int identifier)
                                            throws AdminNotFound
Throws:
AdminNotFound

getDefaultConsumerAdminServant

protected AbstractAdmin getDefaultConsumerAdminServant()

new_for_consumers_servant

protected AbstractAdmin new_for_consumers_servant(InterFilterGroupOperator filterGroupOperator,
                                                  IntHolder intHolder)

new_for_suppliers_servant

protected AbstractAdmin new_for_suppliers_servant(InterFilterGroupOperator filterGroupOperator,
                                                  IntHolder intHolder)

getDefaultSupplierAdminServant

protected AbstractAdmin getDefaultSupplierAdminServant()

newConsumerAdmin

protected abstract AbstractAdmin newConsumerAdmin(int id)

newSupplierAdmin

protected abstract AbstractSupplierAdmin newSupplierAdmin(int id)

getID

public int getID()

addDisposeHook

public final void addDisposeHook(Disposable d)