public abstract class AbstractEventChannel extends Object implements IServantLifecyle, JMXManageable
JMXManageable.JMXCallback
Modifier and Type | Field and Description |
---|---|
protected MutablePicoContainer |
container_ |
protected JMXManageable.JMXCallback |
jmxCallback_ |
protected org.slf4j.Logger |
logger_ |
protected ORB |
orb_ |
Constructor and Description |
---|
AbstractEventChannel(IFactory factory,
ORB orb,
POA poa,
Configuration config,
FilterFactory filterFactory) |
Modifier and Type | Method and Description |
---|---|
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() |
String[] |
getJMXNotificationTypes() |
String |
getJMXObjectName() |
int |
getMaxNumberOfConsumers() |
int |
getMaxNumberOfSuppliers() |
String |
getMBeanName() |
protected abstract String |
getMBeanType() |
int |
getNumberOfConnectedClients()
get the number of clients connected to this event 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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
newServant
protected final org.slf4j.Logger logger_
protected final ORB orb_
protected final MutablePicoContainer container_
protected JMXManageable.JMXCallback jmxCallback_
public AbstractEventChannel(IFactory factory, ORB orb, POA poa, Configuration config, FilterFactory filterFactory)
public final void deactivate()
public final Object activate()
protected final boolean isDefaultConsumerAdminActive()
protected final boolean isDefaultSupplierAdminActive()
public final FilterFactory default_filter_factory()
public final int[] get_all_consumeradmins()
public final int[] get_all_supplieradmins()
public final Property[] get_admin()
public final Property[] get_qos()
public final void set_qos(Property[] props) throws UnsupportedQoS
UnsupportedQoS
public final void validate_qos(Property[] props, NamedPropertyRangeSeqHolder namedPropertySeqHolder) throws UnsupportedQoS
UnsupportedQoS
public final void set_admin(Property[] adminProps) throws UnsupportedAdmin
UnsupportedAdmin
public final void destroy()
public final void dispose()
public final POA getPOA()
getPOA
in interface IServantLifecyle
public boolean isPersistent()
public final int getNumberOfConnectedClients()
public final int getMaxNumberOfSuppliers()
public void setMaxNumberOfSuppliers(int max)
public final int getMaxNumberOfConsumers()
public void setMaxNumberOfConsumers(int max)
protected AbstractAdmin get_consumeradmin_internal(int identifier) throws AdminNotFound
AdminNotFound
protected AbstractAdmin get_supplieradmin_internal(int identifier) throws AdminNotFound
AdminNotFound
protected AbstractAdmin getDefaultConsumerAdminServant()
protected AbstractAdmin new_for_consumers_servant(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
protected AbstractAdmin new_for_suppliers_servant(InterFilterGroupOperator filterGroupOperator, IntHolder intHolder)
protected AbstractAdmin getDefaultSupplierAdminServant()
protected abstract AbstractAdmin newConsumerAdmin(int id)
protected abstract AbstractSupplierAdmin newSupplierAdmin(int id)
public int getID()
public final void registerDisposable(Disposable d)
NotifyingDisposable
registerDisposable
in interface NotifyingDisposable
public final String getJMXObjectName()
getJMXObjectName
in interface JMXManageable
public final String getMBeanName()
protected abstract String getMBeanType()
public String[] getJMXNotificationTypes()
getJMXNotificationTypes
in interface JMXManageable
public void setJMXCallback(JMXManageable.JMXCallback callback)
setJMXCallback
in interface JMXManageable
Copyright © 2017 JacORB. All rights reserved.