org.jacorb.notification.servant

Class AbstractAdmin

public abstract class AbstractAdmin extends Object implements QoSAdminOperations, FilterAdminOperations, FilterStage, IServantLifecyle, JMXManageable

Abstract Baseclass for Adminobjects.

Version: $Id: AbstractAdmin.java,v 1.23 2006/05/23 10:40:35 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN:

Field Summary
protected MutablePicoContainercontainer_
protected static InterFilterGroupOperatorDEFAULT_FILTER_GROUP_OPERATOR
the default InterFilterGroupOperator used.
protected Loggerlogger_
protected ObjectmodifyProxiesLock_
protected OfferManagerofferManager_
protected MappullServants_
protected MappushServants_
protected ServantLifecyleControlservantLifecycle_
protected SubscriptionManagersubscriptionManager_
Constructor Summary
protected AbstractAdmin(IEventChannel channel, ORB orb, POA poa, Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
Method Summary
Objectactivate()
voidaddProxyEventListener(ProxyEventListener l)
protected voidaddProxyToMap(AbstractProxy proxy, Map map, Object lock)
intadd_filter(Filter aFilter)
protected voidconfigureInterFilterGroupOperator(AbstractProxy proxy)
configure the InterFilterGroupOperator a proxy should use.
protected voidconfigureQoS(AbstractProxy proxy)
configure initial QoS Settings for a proxy.
voiddeactivate()
voiddestroy()
voiddispose()
protected voidfireCreateProxyRequestEvent()
intgetChannelID()
ListgetFilters()
IntegergetID()
StringgetInterFilterGroupOperator()
String[]getJMXNotificationTypes()
StringgetJMXObjectName()
MappingFiltergetLifetimeFilter()
admin does not have a lifetime filter
StringgetMBeanName()
protected abstract StringgetMBeanType()
protected MessageFactorygetMessageFactory()
protected ORBgetORB()
POAgetPOA()
MappingFiltergetPriorityFilter()
admin does not have a priority filter
protected AbstractProxygetProxy(int id)
fetch the proxy specified by the provided id. this method will not access an event style proxy.
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.
Filterget_filter(int aFilterId)
Property[]get_qos()
booleanhasInterFilterGroupOperatorOR()
booleanhasLifetimeFilter()
admin does never have a lifetime filter
booleanhasPriorityFilter()
admin does never have a priority filter
booleanisDestroyed()
EventChannelMyChannel()
intMyID()
InterFilterGroupOperatorMyOperator()
protected MutablePicoContainernewContainerForEventStyleProxy()
protected MutablePicoContainernewContainerForNotifyStyleProxy()
protected MutablePicoContainernewContainerForTypedProxy(String supportedInterface)
voidregisterDisposable(Disposable disposable)
voidremoveProxyEventListener(ProxyEventListener listener)
voidremove_all_filters()
voidremove_filter(int aFilterId)
protected voidsendNotification(String type, String message)
voidsetInterFilterGroupOperator(InterFilterGroupOperator operator)
voidsetJMXCallback(JMXManageable.JMXCallback callback)
voidset_qos(Property[] props)
voidvalidate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRangeSeqHolder)

Field Detail

container_

protected final MutablePicoContainer container_

DEFAULT_FILTER_GROUP_OPERATOR

protected static final InterFilterGroupOperator DEFAULT_FILTER_GROUP_OPERATOR
the default InterFilterGroupOperator used.

logger_

protected final Logger logger_

modifyProxiesLock_

protected final Object modifyProxiesLock_

offerManager_

protected final OfferManager offerManager_

pullServants_

protected final Map pullServants_

pushServants_

protected final Map pushServants_

servantLifecycle_

protected final ServantLifecyleControl servantLifecycle_

subscriptionManager_

protected final SubscriptionManager subscriptionManager_

Constructor Detail

AbstractAdmin

protected AbstractAdmin(IEventChannel channel, ORB orb, POA poa, Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)

Method Detail

activate

public final Object activate()

addProxyEventListener

public void addProxyEventListener(ProxyEventListener l)

addProxyToMap

protected void addProxyToMap(AbstractProxy proxy, Map map, Object lock)

add_filter

public int add_filter(Filter aFilter)

configureInterFilterGroupOperator

protected void configureInterFilterGroupOperator(AbstractProxy proxy)
configure the InterFilterGroupOperator a proxy should use.

configureQoS

protected void configureQoS(AbstractProxy proxy)
configure initial QoS Settings for a proxy.

deactivate

public final void deactivate()

destroy

public final void destroy()

UNKNOWN: description = "Destroy this Admin" impact = "ACTION"

dispose

public void dispose()

fireCreateProxyRequestEvent

protected void fireCreateProxyRequestEvent()

getChannelID

public final int getChannelID()

getFilters

public List getFilters()

getID

public Integer getID()

UNKNOWN: description="TODO" access = "read-only" currencyTimeLimit = "2147483647"

getInterFilterGroupOperator

public String getInterFilterGroupOperator()

UNKNOWN: description="TODO" access = "read-only" currencyTimeLimit = "2147483647"

getJMXNotificationTypes

public String[] getJMXNotificationTypes()

getJMXObjectName

public final String getJMXObjectName()

getLifetimeFilter

public MappingFilter getLifetimeFilter()
admin does not have a lifetime filter

getMBeanName

public final String getMBeanName()

getMBeanType

protected abstract String getMBeanType()

getMessageFactory

protected MessageFactory getMessageFactory()

getORB

protected ORB getORB()

getPOA

public final POA getPOA()

getPriorityFilter

public MappingFilter getPriorityFilter()
admin does not have a priority filter

getProxy

protected AbstractProxy getProxy(int id)
fetch the proxy specified by the provided id. this method will not access an event style proxy.

get_all_filters

public int[] get_all_filters()

get_all_notify_proxies

protected int[] get_all_notify_proxies(Map map, Object lock)
return the ID's for all NotifyStyle proxies stored in the provided Map.

get_filter

public Filter get_filter(int aFilterId)

get_qos

public Property[] get_qos()

hasInterFilterGroupOperatorOR

public boolean hasInterFilterGroupOperatorOR()

hasLifetimeFilter

public boolean hasLifetimeFilter()
admin does never have a lifetime filter

hasPriorityFilter

public boolean hasPriorityFilter()
admin does never have a priority filter

isDestroyed

public boolean isDestroyed()

MyChannel

public final EventChannel MyChannel()

MyID

public final int MyID()

MyOperator

public final InterFilterGroupOperator MyOperator()

newContainerForEventStyleProxy

protected MutablePicoContainer newContainerForEventStyleProxy()

newContainerForNotifyStyleProxy

protected MutablePicoContainer newContainerForNotifyStyleProxy()

newContainerForTypedProxy

protected MutablePicoContainer newContainerForTypedProxy(String supportedInterface)

registerDisposable

public final void registerDisposable(Disposable disposable)

removeProxyEventListener

public void removeProxyEventListener(ProxyEventListener listener)

remove_all_filters

public void remove_all_filters()

remove_filter

public void remove_filter(int aFilterId)

sendNotification

protected final void sendNotification(String type, String message)

setInterFilterGroupOperator

public void setInterFilterGroupOperator(InterFilterGroupOperator operator)

setJMXCallback

public final void setJMXCallback(JMXManageable.JMXCallback callback)

set_qos

public void set_qos(Property[] props)

validate_qos

public void validate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRangeSeqHolder)