|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.servant.AbstractAdmin
public abstract class AbstractAdmin
Abstract Baseclass for Adminobjects.
Field Summary | |
---|---|
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()
|
protected |
AbstractAdmin(ChannelContext channelContext)
|
Method Summary | |
---|---|
POA |
_default_POA()
|
int |
add_filter(Filter aFilter)
|
void |
addProxyEventListener(ProxyEventListener l)
|
protected void |
addProxyToMap(AbstractProxy proxy,
java.util.Map map,
java.lang.Object lock)
|
void |
configure(org.apache.avalon.framework.configuration.Configuration conf)
|
protected void |
configureEventStyleID(AbstractProxy proxy)
configure a event style proxy. the key is only for internal use. especially the key cannot used to fetch the proxy via get_proxy_consumer or get_proxy_supplier. |
protected void |
configureInterFilterGroupOperator(AbstractProxy proxy)
configure the InterFilterGroupOperator a proxy should use. |
protected void |
configureManagers(AbstractProxy proxy)
configure OfferManager and SubscriptionManager for a proxy. |
protected void |
configureNotifyStyleID(AbstractProxy proxy)
configure the ID for a notify style proxy. the id is public. the proxy can be accessed via a call to get_proxy_consumer or get_proxy_supplier. |
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()
|
ChannelContext |
getChannelContext()
|
protected EventChannelImpl |
getChannelServant()
|
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()
|
void |
preActivate()
satisfy method implementation |
void |
remove_all_filters()
|
void |
remove_filter(int aFilterId)
|
void |
removeProxyEventListener(ProxyEventListener listener)
|
void |
set_qos(Property[] props)
|
void |
setDisposeHook(java.lang.Runnable disposeHook)
|
void |
setID(java.lang.Integer id)
|
void |
setInterFilterGroupOperator(InterFilterGroupOperator op)
|
void |
setIsIDPublic(boolean isIDPublic)
|
void |
setOfferManager(OfferManager offerManager)
|
void |
setORB(ORB orb)
|
void |
setPOA(POA poa)
|
void |
setSubscriptionManager(SubscriptionManager subscriptionManager)
|
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, getSubsequentFilterStages, hasMessageConsumer |
Methods inherited from interface org.jacorb.notification.servant.ManageableServant |
---|
activate |
Field Detail |
---|
protected static final InterFilterGroupOperator DEFAULT_FILTER_GROUP_OPERATOR
protected OfferManager offerManager_
protected SubscriptionManager subscriptionManager_
protected 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_
Constructor Detail |
---|
protected AbstractAdmin()
protected AbstractAdmin(ChannelContext channelContext)
Method Detail |
---|
public void configure(org.apache.avalon.framework.configuration.Configuration conf)
configure
in interface org.apache.avalon.framework.configuration.Configurable
public ChannelContext getChannelContext()
public void setDisposeHook(java.lang.Runnable disposeHook)
public void setInterFilterGroupOperator(InterFilterGroupOperator op)
public void setID(java.lang.Integer id)
public void setIsIDPublic(boolean isIDPublic)
protected POA getPOA()
public void setPOA(POA poa)
setPOA
in interface ManageableServant
protected ORB getORB()
public void setORB(ORB orb)
setORB
in interface ManageableServant
protected MessageFactory getMessageFactory()
protected EventChannelImpl getChannelServant()
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 InterFilterGroupOperator MyOperator()
public EventChannel MyChannel()
public 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 void setOfferManager(OfferManager offerManager)
public void setSubscriptionManager(SubscriptionManager subscriptionManager)
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 configureEventStyleID(AbstractProxy proxy)
protected void configureNotifyStyleID(AbstractProxy proxy)
protected void configureQoS(AbstractProxy proxy)
protected void configureInterFilterGroupOperator(AbstractProxy proxy)
protected void configureManagers(AbstractProxy proxy)
public void preActivate()
preActivate
in interface ManageableServant
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()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |