|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.servant.AbstractAdmin
Abstract Baseclass for Adminobjects.
Nested Class Summary |
---|
Nested classes inherited from class org.jacorb.notification.interfaces.JMXManageable |
---|
JMXManageable.JMXCallback |
Field Summary | |
---|---|
protected org.picocontainer.MutablePicoContainer |
container_
|
protected static InterFilterGroupOperator |
DEFAULT_FILTER_GROUP_OPERATOR
the default InterFilterGroupOperator used. |
protected org.apache.avalon.framework.logger.Logger |
logger_
|
protected java.lang.Object |
modifyProxiesLock_
|
protected OfferManager |
offerManager_
|
protected java.util.Map |
pullServants_
|
protected java.util.Map |
pushServants_
|
protected ServantLifecyleControl |
servantLifecycle_
|
protected SubscriptionManager |
subscriptionManager_
|
Constructor Summary | |
---|---|
protected |
AbstractAdmin(IEventChannel channel,
ORB orb,
POA poa,
org.apache.avalon.framework.configuration.Configuration config,
MessageFactory messageFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager)
|
Method Summary | |
---|---|
Object |
activate()
|
int |
add_filter(Filter aFilter)
|
void |
addProxyEventListener(ProxyEventListener l)
|
protected void |
addProxyToMap(AbstractProxy proxy,
java.util.Map map,
java.lang.Object lock)
|
protected void |
configureInterFilterGroupOperator(AbstractProxy proxy)
configure the InterFilterGroupOperator a proxy should use. |
protected void |
configureQoS(AbstractProxy proxy)
configure initial QoS Settings for a proxy. |
void |
deactivate()
|
void |
destroy()
|
void |
dispose()
|
protected void |
fireCreateProxyRequestEvent()
|
int[] |
get_all_filters()
|
protected int[] |
get_all_notify_proxies(java.util.Map map,
java.lang.Object lock)
return the ID's for all NotifyStyle proxies stored in the provided Map. |
Filter |
get_filter(int aFilterId)
|
Property[] |
get_qos()
|
int |
getChannelID()
|
java.util.List |
getFilters()
get Filters associated to this FilterStage. |
java.lang.Integer |
getID()
|
java.lang.String |
getInterFilterGroupOperator()
|
java.lang.String[] |
getJMXNotificationTypes()
|
java.lang.String |
getJMXObjectName()
|
MappingFilter |
getLifetimeFilter()
admin does not have a lifetime filter |
java.lang.String |
getMBeanName()
|
protected abstract java.lang.String |
getMBeanType()
|
protected MessageFactory |
getMessageFactory()
|
protected ORB |
getORB()
|
POA |
getPOA()
|
MappingFilter |
getPriorityFilter()
admin does not have a priority filter |
protected AbstractProxy |
getProxy(int id)
fetch the proxy specified by the provided id. this method will not access an event style proxy. |
boolean |
hasInterFilterGroupOperatorOR()
check if this FilterStage has OR Semantic enabled. |
boolean |
hasLifetimeFilter()
admin does never have a lifetime filter |
boolean |
hasPriorityFilter()
admin does never have a priority filter |
boolean |
isDestroyed()
check if this FilterStage has been disposed. |
EventChannel |
MyChannel()
|
int |
MyID()
|
InterFilterGroupOperator |
MyOperator()
|
protected org.picocontainer.MutablePicoContainer |
newContainerForEventStyleProxy()
|
protected org.picocontainer.MutablePicoContainer |
newContainerForNotifyStyleProxy()
|
protected org.picocontainer.MutablePicoContainer |
newContainerForTypedProxy(java.lang.String supportedInterface)
|
void |
registerDisposable(Disposable disposable)
the hooks registered by this method will be run when dispose is called. |
void |
remove_all_filters()
|
void |
remove_filter(int aFilterId)
|
void |
removeProxyEventListener(ProxyEventListener listener)
|
protected void |
sendNotification(java.lang.String type,
java.lang.String message)
|
void |
set_qos(Property[] props)
|
void |
setInterFilterGroupOperator(InterFilterGroupOperator operator)
|
void |
setJMXCallback(JMXManageable.JMXCallback callback)
|
void |
validate_qos(Property[] props,
NamedPropertyRangeSeqHolder propertyRangeSeqHolder)
|
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.interfaces.FilterStage |
---|
getMessageConsumer, hasMessageConsumer |
Methods inherited from interface org.jacorb.notification.interfaces.FilterStageSource |
---|
getSubsequentFilterStages |
Methods inherited from interface org.jacorb.notification.lifecycle.IServantLifecyle |
---|
newServant |
Field Detail |
protected static final InterFilterGroupOperator DEFAULT_FILTER_GROUP_OPERATOR
protected final org.picocontainer.MutablePicoContainer container_
protected final OfferManager offerManager_
protected final SubscriptionManager subscriptionManager_
protected final org.apache.avalon.framework.logger.Logger logger_
protected final java.lang.Object modifyProxiesLock_
protected final java.util.Map pullServants_
protected final java.util.Map pushServants_
protected final ServantLifecyleControl servantLifecycle_
Constructor Detail |
protected AbstractAdmin(IEventChannel channel, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
Method Detail |
public final void registerDisposable(Disposable disposable)
NotifyingDisposable
registerDisposable
in interface NotifyingDisposable
public void setInterFilterGroupOperator(InterFilterGroupOperator operator)
public final POA getPOA()
getPOA
in interface IServantLifecyle
protected ORB getORB()
protected MessageFactory getMessageFactory()
public java.util.List getFilters()
FilterStage
getFilters
in interface FilterStage
public int add_filter(Filter aFilter)
add_filter
in interface FilterAdminOperations
public void remove_filter(int aFilterId) throws FilterNotFound
remove_filter
in interface FilterAdminOperations
FilterNotFound
public Filter get_filter(int aFilterId) throws FilterNotFound
get_filter
in interface FilterAdminOperations
FilterNotFound
public int[] get_all_filters()
get_all_filters
in interface FilterAdminOperations
public void remove_all_filters()
remove_all_filters
in interface FilterAdminOperations
public final InterFilterGroupOperator MyOperator()
public final EventChannel MyChannel()
public final int MyID()
public final int getChannelID()
public Property[] get_qos()
get_qos
in interface QoSAdminOperations
public void set_qos(Property[] props) throws UnsupportedQoS
set_qos
in interface QoSAdminOperations
UnsupportedQoS
public void validate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRangeSeqHolder) throws UnsupportedQoS
validate_qos
in interface QoSAdminOperations
UnsupportedQoS
public final void destroy()
public void dispose()
dispose
in interface org.picocontainer.Disposable
public final Object activate()
public final void deactivate()
public java.lang.Integer getID()
public boolean isDestroyed()
FilterStage
isDestroyed
in interface FilterStage
protected void fireCreateProxyRequestEvent() throws AdminLimitExceeded
AdminLimitExceeded
public boolean hasLifetimeFilter()
hasLifetimeFilter
in interface FilterStage
public boolean hasPriorityFilter()
hasPriorityFilter
in interface FilterStage
public MappingFilter getLifetimeFilter()
getLifetimeFilter
in interface FilterStage
public MappingFilter getPriorityFilter()
getPriorityFilter
in interface FilterStage
public java.lang.String getInterFilterGroupOperator()
public boolean hasInterFilterGroupOperatorOR()
FilterStage
hasInterFilterGroupOperatorOR
in interface FilterStage
protected AbstractProxy getProxy(int id) throws ProxyNotFound
ProxyNotFound
protected int[] get_all_notify_proxies(java.util.Map map, java.lang.Object lock)
protected void configureQoS(AbstractProxy proxy) throws UnsupportedQoS
UnsupportedQoS
protected void configureInterFilterGroupOperator(AbstractProxy proxy)
public void addProxyEventListener(ProxyEventListener l)
public void removeProxyEventListener(ProxyEventListener listener)
protected void addProxyToMap(AbstractProxy proxy, java.util.Map map, java.lang.Object lock)
protected org.picocontainer.MutablePicoContainer newContainerForNotifyStyleProxy()
protected org.picocontainer.MutablePicoContainer newContainerForEventStyleProxy()
protected org.picocontainer.MutablePicoContainer newContainerForTypedProxy(java.lang.String supportedInterface)
public final java.lang.String getJMXObjectName()
getJMXObjectName
in interface JMXManageable
public final java.lang.String getMBeanName()
protected abstract java.lang.String getMBeanType()
public java.lang.String[] getJMXNotificationTypes()
getJMXNotificationTypes
in interface JMXManageable
public final void setJMXCallback(JMXManageable.JMXCallback callback)
setJMXCallback
in interface JMXManageable
protected final void sendNotification(java.lang.String type, java.lang.String message)
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |