org.jacorb.notification.servant

Class AbstractAdmin

Implemented Interfaces:
Configurable, FilterAdminOperations, FilterStage, ManageableServant, QoSAdminOperations
Known Direct Subclasses:
ConsumerAdminTieImpl, SupplierAdminTieImpl

public abstract class AbstractAdmin
extends java.lang.Object
implements QoSAdminOperations, FilterAdminOperations, FilterStage, ManageableServant, Configurable

Abstract Baseclass for Adminobjects.

Version:
$Id: AbstractAdmin.java,v 1.8 2004/05/06 12:39:59 nicolas Exp $

Author:
Alphonse Bendt

Field Summary

protected static InterFilterGroupOperator
DEFAULT_FILTER_GROUP_OPERATOR
the default InterFilterGroupOperator used.
protected Logger
logger_
protected Object
modifyProxiesLock_
protected OfferManager
offerManager_
protected Map
pullServants_
protected Map
pushServants_
protected SubscriptionManager
subscriptionManager_

Constructor Summary

AbstractAdmin()
AbstractAdmin(ChannelContext channelContext)

Method Summary

EventChannel
MyChannel()
int
MyID()
InterFilterGroupOperator
MyOperator()
POA
_default_POA()
void
addProxyEventListener(ProxyEventListener l)
protected void
addProxyToMap(AbstractProxy proxy, Map map, Object lock)
int
add_filter(Filter aFilter)
void
configure(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()
ChannelContext
getChannelContext()
protected EventChannelImpl
getChannelServant()
List
getFilters()
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
List
getProxies()
protected AbstractProxy
getProxy(int id)
fetch the proxy specified by the provided id. this method will not access an event style proxy.
Servant
getServant()
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()
boolean
hasInterFilterGroupOperatorOR()
boolean
hasLifetimeFilter()
admin does not have a lifetime filter
boolean
hasPriorityFilter()
admin does not have a priority filter
boolean
isDisposed()
void
preActivate()
satisfy method implementation
void
removeProxyEventListener(ProxyEventListener listener)
void
remove_all_filters()
void
remove_filter(int aFilterId)
void
setDisposeHook(Runnable disposeHook)
void
setID(Integer id)
void
setInterFilterGroupOperator(InterFilterGroupOperator op)
void
setIsIDPublic(boolean isIDPublic)
void
setORB(ORB orb)
void
setOfferManager(OfferManager offerManager)
void
setPOA(POA poa)
void
setSubscriptionManager(SubscriptionManager subscriptionManager)
void
set_qos(Property props)
void
validate_qos(Property props, NamedPropertyRangeSeqHolder propertyRangeSeqHolder)

Field Details

DEFAULT_FILTER_GROUP_OPERATOR

protected static final InterFilterGroupOperator DEFAULT_FILTER_GROUP_OPERATOR
the default InterFilterGroupOperator used.


logger_

protected Logger logger_


modifyProxiesLock_

protected final Object modifyProxiesLock_


offerManager_

protected OfferManager offerManager_


pullServants_

protected final Map pullServants_


pushServants_

protected final Map pushServants_


subscriptionManager_

protected SubscriptionManager subscriptionManager_

Constructor Details

AbstractAdmin

protected AbstractAdmin()


AbstractAdmin

protected AbstractAdmin(ChannelContext channelContext)

Method Details

MyChannel

public EventChannel MyChannel()


MyID

public int MyID()


MyOperator

public InterFilterGroupOperator MyOperator()


_default_POA

public POA _default_POA()


addProxyEventListener

public void addProxyEventListener(ProxyEventListener l)


addProxyToMap

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


add_filter

public int add_filter(Filter aFilter)
Specified by:
add_filter in interface FilterAdminOperations


configure

public void configure(Configuration conf)


configureEventStyleID

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.


configureInterFilterGroupOperator

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


configureManagers

protected void configureManagers(AbstractProxy proxy)
configure OfferManager and SubscriptionManager for a proxy.


configureNotifyStyleID

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.


configureQoS

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


deactivate

public void deactivate()
Specified by:
deactivate in interface ManageableServant


destroy

public void destroy()


dispose

public void dispose()


fireCreateProxyRequestEvent

protected void fireCreateProxyRequestEvent()
            throws AdminLimitExceeded


getChannelContext

public ChannelContext getChannelContext()


getChannelServant

protected EventChannelImpl getChannelServant()


getFilters

public List getFilters()
Specified by:
getFilters in interface FilterStage


getID

public Integer getID()


getLifetimeFilter

public MappingFilter getLifetimeFilter()
admin does not have a lifetime filter
Specified by:
getLifetimeFilter in interface FilterStage


getMessageFactory

protected MessageFactory getMessageFactory()


getORB

protected ORB getORB()


getPOA

protected POA getPOA()


getPriorityFilter

public MappingFilter getPriorityFilter()
admin does not have a priority filter
Specified by:
getPriorityFilter in interface FilterStage


getProxies

public final List getProxies()


getProxy

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


getServant

public Servant getServant()


get_all_filters

public int[] get_all_filters()
Specified by:
get_all_filters in interface FilterAdminOperations


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)
            throws FilterNotFound
Specified by:
get_filter in interface FilterAdminOperations


get_qos

public Property[] get_qos()
Specified by:
get_qos in interface QoSAdminOperations


hasInterFilterGroupOperatorOR

public boolean hasInterFilterGroupOperatorOR()
Specified by:
hasInterFilterGroupOperatorOR in interface FilterStage


hasLifetimeFilter

public boolean hasLifetimeFilter()
admin does not have a lifetime filter
Specified by:
hasLifetimeFilter in interface FilterStage


hasPriorityFilter

public boolean hasPriorityFilter()
admin does not have a priority filter
Specified by:
hasPriorityFilter in interface FilterStage


isDisposed

public boolean isDisposed()
Specified by:
isDisposed in interface FilterStage


preActivate

public void preActivate()
satisfy method implementation
Specified by:
preActivate in interface ManageableServant


removeProxyEventListener

public void removeProxyEventListener(ProxyEventListener listener)


remove_all_filters

public void remove_all_filters()
Specified by:
remove_all_filters in interface FilterAdminOperations


remove_filter

public void remove_filter(int aFilterId)
            throws FilterNotFound
Specified by:
remove_filter in interface FilterAdminOperations


setDisposeHook

public void setDisposeHook(Runnable disposeHook)


setID

public void setID(Integer id)


setInterFilterGroupOperator

public void setInterFilterGroupOperator(InterFilterGroupOperator op)


setIsIDPublic

public void setIsIDPublic(boolean isIDPublic)


setORB

public void setORB(ORB orb)
Specified by:
setORB in interface ManageableServant


setOfferManager

public void setOfferManager(OfferManager offerManager)


setPOA

public void setPOA(POA poa)
Specified by:
setPOA in interface ManageableServant


setSubscriptionManager

public void setSubscriptionManager(SubscriptionManager subscriptionManager)


set_qos

public void set_qos(Property props)
            throws UnsupportedQoS


validate_qos

public void validate_qos(Property props,
                         NamedPropertyRangeSeqHolder propertyRangeSeqHolder)
            throws UnsupportedQoS