public abstract class AbstractAdmin extends Object implements QoSAdminOperations, FilterAdminOperations, FilterStage, IServantLifecyle, JMXManageable
JMXManageable.JMXCallback
Modifier and Type | Field and Description |
---|---|
protected MutablePicoContainer |
container_ |
protected static InterFilterGroupOperator |
DEFAULT_FILTER_GROUP_OPERATOR
the default InterFilterGroupOperator used.
|
protected org.slf4j.Logger |
logger_ |
protected Object |
modifyProxiesLock_ |
protected OfferManager |
offerManager_ |
protected Map |
pullServants_ |
protected Map |
pushServants_ |
protected ServantLifecyleControl |
servantLifecycle_ |
protected SubscriptionManager |
subscriptionManager_ |
Modifier | Constructor and Description |
---|---|
protected |
AbstractAdmin(IEventChannel channel,
ORB orb,
POA poa,
Configuration config,
MessageFactory messageFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
Modifier and Type | Method and Description |
---|---|
Object |
activate() |
int |
add_filter(Filter aFilter) |
void |
addProxyEventListener(ProxyEventListener l) |
protected void |
addProxyToMap(AbstractProxy proxy,
Map map,
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(Map map,
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() |
List |
getFilters()
get Filters associated to this FilterStage.
|
Integer |
getID() |
String |
getInterFilterGroupOperator() |
String[] |
getJMXNotificationTypes() |
String |
getJMXObjectName() |
MappingFilter |
getLifetimeFilter()
admin does not have a lifetime filter
|
String |
getMBeanName() |
protected abstract 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.
|
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 MutablePicoContainer |
newContainerForEventStyleProxy() |
protected MutablePicoContainer |
newContainerForNotifyStyleProxy() |
protected MutablePicoContainer |
newContainerForTypedProxy(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(String type,
String message) |
void |
set_qos(Property[] props) |
void |
setInterFilterGroupOperator(InterFilterGroupOperator operator) |
void |
setJMXCallback(JMXManageable.JMXCallback callback) |
void |
validate_qos(Property[] props,
NamedPropertyRangeSeqHolder propertyRangeSeqHolder) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getMessageConsumer, hasMessageConsumer
getSubsequentFilterStages
newServant
protected static final InterFilterGroupOperator DEFAULT_FILTER_GROUP_OPERATOR
protected final MutablePicoContainer container_
protected final OfferManager offerManager_
protected final SubscriptionManager subscriptionManager_
protected final org.slf4j.Logger logger_
protected final Object modifyProxiesLock_
protected final Map pullServants_
protected final Map pushServants_
protected final ServantLifecyleControl servantLifecycle_
protected AbstractAdmin(IEventChannel channel, ORB orb, POA poa, Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
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 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()
public final Object activate()
public final void deactivate()
public 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 String getInterFilterGroupOperator()
public boolean hasInterFilterGroupOperatorOR()
FilterStage
hasInterFilterGroupOperatorOR
in interface FilterStage
protected AbstractProxy getProxy(int id) throws ProxyNotFound
ProxyNotFound
protected int[] get_all_notify_proxies(Map map, 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, Map map, Object lock)
protected MutablePicoContainer newContainerForNotifyStyleProxy()
protected MutablePicoContainer newContainerForEventStyleProxy()
protected MutablePicoContainer newContainerForTypedProxy(String supportedInterface)
public final String getJMXObjectName()
getJMXObjectName
in interface JMXManageable
public final String getMBeanName()
protected abstract String getMBeanType()
public String[] getJMXNotificationTypes()
getJMXNotificationTypes
in interface JMXManageable
public final void setJMXCallback(JMXManageable.JMXCallback callback)
setJMXCallback
in interface JMXManageable
Copyright © 2016 JacORB. All rights reserved.