org.jacorb.notification
Class AbstractEventChannel
java.lang.Object
org.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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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_
AbstractEventChannel
public AbstractEventChannel(IFactory factory,
ORB orb,
POA poa,
org.apache.avalon.framework.configuration.Configuration config,
FilterFactory filterFactory)
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