org.jacorb.notification
Class AbstractEventChannel

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

public abstract class AbstractEventChannel
extends java.lang.Object
implements IServantLifecyle, JMXManageable

Version:
$Id: AbstractEventChannel.java,v 1.13 2006/02/20 19:25:07 alphonse.bendt Exp $
Author:
Alphonse Bendt

Nested Class Summary
 
Nested classes inherited from class org.jacorb.notification.interfaces.JMXManageable
JMXManageable.JMXCallback
 
Field Summary
protected  org.picocontainer.MutablePicoContainer container_
           
protected  JMXManageable.JMXCallback jmxCallback_
           
protected  org.apache.avalon.framework.logger.Logger logger_
           
protected  ORB orb_
           
 
Constructor Summary
AbstractEventChannel(IFactory factory, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration config, FilterFactory filterFactory)
           
 
Method Summary
 Object activate()
           
 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)
           
protected  AbstractAdmin getDefaultConsumerAdminServant()
           
protected  AbstractAdmin getDefaultSupplierAdminServant()
           
 int getID()
           
 java.lang.String[] getJMXNotificationTypes()
           
 java.lang.String getJMXObjectName()
           
 int getMaxNumberOfConsumers()
           
 int getMaxNumberOfSuppliers()
           
 java.lang.String getMBeanName()
           
protected abstract  java.lang.String getMBeanType()
           
 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.
 POA getPOA()
           
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 registerDisposable(Disposable d)
          the hooks registered by this method will be run when dispose is called.
 void set_admin(Property[] adminProps)
           
 void set_qos(Property[] props)
           
 void setJMXCallback(JMXManageable.JMXCallback callback)
           
 void setMaxNumberOfConsumers(int max)
           
 void setMaxNumberOfSuppliers(int max)
           
 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.lifecycle.IServantLifecyle
newServant
 

Field Detail

logger_

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

orb_

protected final ORB orb_

container_

protected final org.picocontainer.MutablePicoContainer container_

jmxCallback_

protected JMXManageable.JMXCallback jmxCallback_
Constructor Detail

AbstractEventChannel

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

deactivate

public final void deactivate()

activate

public final Object activate()

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

getPOA

public final POA getPOA()
Specified by:
getPOA in interface IServantLifecyle

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()

setMaxNumberOfSuppliers

public void setMaxNumberOfSuppliers(int max)

getMaxNumberOfConsumers

public final int getMaxNumberOfConsumers()

setMaxNumberOfConsumers

public void setMaxNumberOfConsumers(int max)

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()

registerDisposable

public final void registerDisposable(Disposable d)
Description copied from interface: NotifyingDisposable
the hooks registered by this method will be run when dispose is called.

Specified by:
registerDisposable in interface NotifyingDisposable

getJMXObjectName

public final java.lang.String getJMXObjectName()
Specified by:
getJMXObjectName in interface JMXManageable

getMBeanName

public final java.lang.String getMBeanName()

getMBeanType

protected abstract java.lang.String getMBeanType()

getJMXNotificationTypes

public java.lang.String[] getJMXNotificationTypes()
Specified by:
getJMXNotificationTypes in interface JMXManageable

setJMXCallback

public void setJMXCallback(JMXManageable.JMXCallback callback)
Specified by:
setJMXCallback in interface JMXManageable