|
||||||||||||
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.
Field Summary | |
---|---|
int |
channelID_
|
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 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 | |
---|---|
POA |
_default_POA()
|
int |
add_filter(Filter aFilter)
|
void |
addDisposeHook(Disposable d)
|
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()
|
java.util.List |
getFilters()
get Filters associated to this FilterStage. |
java.lang.Integer |
getID()
|
MappingFilter |
getLifetimeFilter()
admin does not have a lifetime filter |
protected MessageFactory |
getMessageFactory()
|
protected ORB |
getORB()
|
protected POA |
getPOA()
|
MappingFilter |
getPriorityFilter()
admin does not have a priority filter |
java.util.List |
getProxies()
|
protected AbstractProxy |
getProxy(int id)
fetch the proxy specified by the provided id. this method will not access an event style proxy. |
abstract Servant |
getServant()
|
boolean |
hasInterFilterGroupOperatorOR()
check if this FilterStage has OR Semantic enabled. |
boolean |
hasLifetimeFilter()
admin does not have a lifetime filter |
boolean |
hasPriorityFilter()
admin does not have a priority filter |
boolean |
isDisposed()
check if this FilterStage has been disposed. |
EventChannel |
MyChannel()
|
int |
MyID()
|
InterFilterGroupOperator |
MyOperator()
|
protected org.picocontainer.ComponentAdapter |
newComponentAdapter(java.lang.Object key,
java.lang.Class implementation)
|
protected org.picocontainer.MutablePicoContainer |
newContainerForEventStyleProxy()
|
protected org.picocontainer.MutablePicoContainer |
newContainerForNotifyStyleProxy()
|
protected org.picocontainer.MutablePicoContainer |
newContainerForTypedProxy(java.lang.String supportedInterface)
|
void |
remove_all_filters()
|
void |
remove_filter(int aFilterId)
|
void |
removeProxyEventListener(ProxyEventListener listener)
|
void |
set_qos(Property[] props)
|
void |
setInterFilterGroupOperator(InterFilterGroupOperator op)
|
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.servant.ManageableServant |
---|
activate |
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_
public final int channelID_
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 addDisposeHook(Disposable d)
public void setInterFilterGroupOperator(InterFilterGroupOperator op)
protected POA getPOA()
protected ORB getORB()
protected MessageFactory getMessageFactory()
public POA _default_POA()
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 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 void destroy()
public void dispose()
public void deactivate()
deactivate
in interface ManageableServant
public abstract Servant getServant()
public java.lang.Integer getID()
public boolean isDisposed()
FilterStage
isDisposed
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 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)
public final java.util.List getProxies()
protected org.picocontainer.MutablePicoContainer newContainerForNotifyStyleProxy()
protected org.picocontainer.MutablePicoContainer newContainerForEventStyleProxy()
protected org.picocontainer.MutablePicoContainer newContainerForTypedProxy(java.lang.String supportedInterface)
protected org.picocontainer.ComponentAdapter newComponentAdapter(java.lang.Object key, java.lang.Class implementation)
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |