org.jacorb.notification

Class AbstractEventChannel

public abstract class AbstractEventChannel extends Object implements IServantLifecyle, JMXManageable

Version: $Id: AbstractEventChannel.java,v 1.14 2006/05/23 10:22:20 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN:

Field Summary
protected MutablePicoContainercontainer_
protected JMXManageable.JMXCallbackjmxCallback_
protected Loggerlogger_
protected ORBorb_
Constructor Summary
AbstractEventChannel(IFactory factory, ORB orb, POA poa, Configuration config, FilterFactory filterFactory)
Method Summary
Objectactivate()
voiddeactivate()
FilterFactorydefault_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.
voiddestroy()
destroy this Channel, all created Admins and all Proxies.
voiddispose()
protected AbstractAdmingetDefaultConsumerAdminServant()
protected AbstractAdmingetDefaultSupplierAdminServant()
intgetID()
String[]getJMXNotificationTypes()
StringgetJMXObjectName()
intgetMaxNumberOfConsumers()
intgetMaxNumberOfSuppliers()
StringgetMBeanName()
protected abstract StringgetMBeanType()
intgetNumberOfConnectedClients()
get the number of clients connected to this event channel. the number is the total of all Suppliers and Consumers connected to this channel.
POAgetPOA()
Property[]get_admin()
int[]get_all_consumeradmins()
int[]get_all_supplieradmins()
protected AbstractAdminget_consumeradmin_internal(int identifier)
Property[]get_qos()
protected AbstractAdminget_supplieradmin_internal(int identifier)
protected booleanisDefaultConsumerAdminActive()
protected booleanisDefaultSupplierAdminActive()
booleanisPersistent()
protected abstract AbstractAdminnewConsumerAdmin(int id)
protected abstract AbstractSupplierAdminnewSupplierAdmin(int id)
protected AbstractAdminnew_for_consumers_servant(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
protected AbstractAdminnew_for_suppliers_servant(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
voidregisterDisposable(Disposable d)
voidsetJMXCallback(JMXManageable.JMXCallback callback)
voidsetMaxNumberOfConsumers(int max)
voidsetMaxNumberOfSuppliers(int max)
voidset_admin(Property[] adminProps)
voidset_qos(Property[] props)
voidvalidate_qos(Property[] props, NamedPropertyRangeSeqHolder namedPropertySeqHolder)

Field Detail

container_

protected final MutablePicoContainer container_

jmxCallback_

protected JMXManageable.JMXCallback jmxCallback_

logger_

protected final Logger logger_

orb_

protected final ORB orb_

Constructor Detail

AbstractEventChannel

public AbstractEventChannel(IFactory factory, ORB orb, POA poa, Configuration config, FilterFactory filterFactory)

Method Detail

activate

public final Object activate()

deactivate

public final void deactivate()

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.

destroy

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

UNKNOWN: description = "Destroy this Channel" impact = "ACTION"

dispose

public final void dispose()

getDefaultConsumerAdminServant

protected AbstractAdmin getDefaultConsumerAdminServant()

getDefaultSupplierAdminServant

protected AbstractAdmin getDefaultSupplierAdminServant()

getID

public int getID()

UNKNOWN: description="ID that identifies this EventChannel" access = "read-only" currencyTimeLimit = "2147483647"

getJMXNotificationTypes

public String[] getJMXNotificationTypes()

getJMXObjectName

public final String getJMXObjectName()

getMaxNumberOfConsumers

public final int getMaxNumberOfConsumers()

UNKNOWN: description = "maximum number of consumers that are allowed at a time" access = "read-write"

getMaxNumberOfSuppliers

public final int getMaxNumberOfSuppliers()

UNKNOWN: description = "maximum number of suppliers that are allowed at a time" access = "read-write"

getMBeanName

public final String getMBeanName()

getMBeanType

protected abstract String getMBeanType()

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.

getPOA

public final POA getPOA()

get_admin

public final Property[] get_admin()

get_all_consumeradmins

public final int[] get_all_consumeradmins()

get_all_supplieradmins

public final int[] get_all_supplieradmins()

get_consumeradmin_internal

protected AbstractAdmin get_consumeradmin_internal(int identifier)

get_qos

public final Property[] get_qos()

get_supplieradmin_internal

protected AbstractAdmin get_supplieradmin_internal(int identifier)

isDefaultConsumerAdminActive

protected final boolean isDefaultConsumerAdminActive()

isDefaultSupplierAdminActive

protected final boolean isDefaultSupplierAdminActive()

isPersistent

public boolean isPersistent()

newConsumerAdmin

protected abstract AbstractAdmin newConsumerAdmin(int id)

newSupplierAdmin

protected abstract AbstractSupplierAdmin newSupplierAdmin(int id)

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)

registerDisposable

public final void registerDisposable(Disposable d)

setJMXCallback

public void setJMXCallback(JMXManageable.JMXCallback callback)

setMaxNumberOfConsumers

public void setMaxNumberOfConsumers(int max)

UNKNOWN: access = "read-write"

setMaxNumberOfSuppliers

public void setMaxNumberOfSuppliers(int max)

UNKNOWN: access = "read-write"

set_admin

public final void set_admin(Property[] adminProps)

set_qos

public final void set_qos(Property[] props)

validate_qos

public final void validate_qos(Property[] props, NamedPropertyRangeSeqHolder namedPropertySeqHolder)