|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.servant.AbstractProxy
Nested Class Summary |
---|
Nested classes inherited from class org.jacorb.notification.interfaces.JMXManageable |
---|
JMXManageable.JMXCallback |
Field Summary | |
---|---|
protected org.apache.avalon.framework.configuration.Configuration |
config_
|
protected java.util.Set |
eventTypes_
|
protected org.apache.avalon.framework.logger.Logger |
logger_
|
protected OfferManager |
offerManager_
|
protected QoSPropertySet |
qosSettings_
|
protected SubscriptionManager |
subscriptionManager_
|
Constructor Summary | |
---|---|
protected |
AbstractProxy(IAdmin admin,
ORB orb,
POA poa,
org.apache.avalon.framework.configuration.Configuration conf,
TaskProcessor taskProcessor,
OfferManager offerManager,
SubscriptionManager subscriptionManager)
|
Method Summary | |
---|---|
Object |
activate()
|
int |
add_filter(Filter filter)
|
protected void |
checkDestroyStatus()
|
protected void |
checkIsConnected()
|
protected void |
checkIsNotConnected()
|
protected void |
checkStillConnected()
|
protected abstract void |
clientDisconnected()
|
void |
configure(org.apache.avalon.framework.configuration.Configuration conf)
|
protected void |
connectClient(Object client)
|
protected void |
connectionResumed()
this is an extension point. invoked when resume_connection was called successfully. |
protected void |
connectionSuspended()
this is an extension point. |
void |
deactivate()
|
void |
destroy()
|
protected abstract void |
disconnectClient()
invoke the proxy specific disconnect method. |
void |
dispose()
|
int[] |
get_all_filters()
|
Filter |
get_filter(int n)
|
Property[] |
get_qos()
|
java.lang.String |
getClientIOR()
|
boolean |
getConnected()
|
int |
getErrorCounter()
|
java.util.List |
getFilters()
get Filters associated to this FilterStage. |
java.lang.Integer |
getID()
|
java.lang.String |
getInterFilterGroupOperator()
|
java.lang.String[] |
getJMXNotificationTypes()
|
java.lang.String |
getJMXObjectName()
|
MappingFilter |
getLifetimeFilter()
access the LifetimeFilter attached to this FilterStage |
java.lang.String |
getMBeanName()
|
protected java.lang.String |
getMBeanType()
|
protected ORB |
getORB()
|
POA |
getPOA()
|
MappingFilter |
getPriorityFilter()
access the PriorityFilter attached to this FilterStage |
java.lang.String |
getStatus()
|
protected TaskProcessor |
getTaskProcessor()
|
protected void |
handleDisconnected(Disconnected e)
|
boolean |
hasInterFilterGroupOperatorOR()
check if this FilterStage has OR Semantic enabled. |
boolean |
hasLifetimeFilter()
check if this FilterStage has a LifetimeFilter attached |
boolean |
hasPriorityFilter()
check if this FilterStage has a PriorityFilter attached |
int |
incErrorCounter()
|
boolean |
isDestroyed()
check if this FilterStage has been disposed. |
boolean |
isIDPublic()
|
boolean |
isSuspended()
|
MappingFilter |
lifetime_filter()
|
void |
lifetime_filter(MappingFilter filter)
|
abstract ProxyType |
MyType()
|
MappingFilter |
priority_filter()
|
void |
priority_filter(MappingFilter filter)
|
void |
registerDisposable(Disposable d)
the hooks registered by this method will be run when dispose is called. |
void |
remove_all_filters()
|
void |
remove_filter(int n)
|
protected abstract void |
removeListener()
|
void |
resetErrorCounter()
|
void |
resume_connection()
|
protected void |
sendNotification(java.lang.String type,
java.lang.String message)
|
protected void |
sendNotification(java.lang.String type,
java.lang.String message,
java.lang.Object payload)
|
void |
set_qos(Property[] qosProps)
|
void |
setJMXCallback(JMXManageable.JMXCallback callback)
|
void |
suspend_connection()
|
void |
validate_event_qos(Property[] qosProps,
NamedPropertyRangeSeqHolder propSeqHolder)
|
void |
validate_qos(Property[] props,
NamedPropertyRangeSeqHolder propertyRange)
|
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.lifecycle.IServantLifecyle |
---|
newServant |
Field Detail |
protected final org.apache.avalon.framework.logger.Logger logger_
protected final QoSPropertySet qosSettings_
protected final OfferManager offerManager_
protected final SubscriptionManager subscriptionManager_
protected final java.util.Set eventTypes_
protected org.apache.avalon.framework.configuration.Configuration config_
Constructor Detail |
protected AbstractProxy(IAdmin admin, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager)
Method Detail |
public void configure(org.apache.avalon.framework.configuration.Configuration conf)
configure
in interface org.apache.avalon.framework.configuration.Configurable
public void registerDisposable(Disposable d)
NotifyingDisposable
registerDisposable
in interface NotifyingDisposable
public boolean isIDPublic()
public final POA getPOA()
getPOA
in interface IServantLifecyle
protected ORB getORB()
public final Object activate()
protected TaskProcessor getTaskProcessor()
public final int add_filter(Filter filter)
add_filter
in interface FilterAdminOperations
public final void remove_filter(int n) throws FilterNotFound
remove_filter
in interface FilterAdminOperations
FilterNotFound
public final Filter get_filter(int n) throws FilterNotFound
get_filter
in interface FilterAdminOperations
FilterNotFound
public final int[] get_all_filters()
get_all_filters
in interface FilterAdminOperations
public final void remove_all_filters()
remove_all_filters
in interface FilterAdminOperations
public void validate_event_qos(Property[] qosProps, NamedPropertyRangeSeqHolder propSeqHolder)
public final void validate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRange) throws UnsupportedQoS
validate_qos
in interface QoSAdminOperations
UnsupportedQoS
public final void set_qos(Property[] qosProps) throws UnsupportedQoS
set_qos
in interface QoSAdminOperations
UnsupportedQoS
public final Property[] get_qos()
get_qos
in interface QoSAdminOperations
public final void priority_filter(MappingFilter filter)
public final MappingFilter priority_filter()
public final MappingFilter lifetime_filter()
public final void lifetime_filter(MappingFilter filter)
public final java.lang.Integer getID()
public final java.util.List getFilters()
FilterStage
getFilters
in interface FilterStage
public final void deactivate()
public final boolean isDestroyed()
FilterStage
isDestroyed
in interface FilterStage
protected void checkDestroyStatus() throws OBJECT_NOT_EXIST
OBJECT_NOT_EXIST
public final void destroy()
destroy
in interface AbstractProxyMBean
public void dispose()
dispose
in interface org.picocontainer.Disposable
protected abstract void clientDisconnected()
public abstract ProxyType MyType()
public final boolean hasInterFilterGroupOperatorOR()
FilterStage
hasInterFilterGroupOperatorOR
in interface FilterStage
public final boolean getConnected()
getConnected
in interface AbstractProxyMBean
public final boolean hasLifetimeFilter()
FilterStage
hasLifetimeFilter
in interface FilterStage
public final boolean hasPriorityFilter()
FilterStage
hasPriorityFilter
in interface FilterStage
public final MappingFilter getLifetimeFilter()
FilterStage
getLifetimeFilter
in interface FilterStage
public final MappingFilter getPriorityFilter()
FilterStage
getPriorityFilter
in interface FilterStage
public void resetErrorCounter()
resetErrorCounter
in interface AbstractProxyMBean
public final int getErrorCounter()
getErrorCounter
in interface AbstractProxyMBean
public final int incErrorCounter()
public boolean isSuspended()
public final void suspend_connection() throws NotConnected, ConnectionAlreadyInactive
NotConnected
ConnectionAlreadyInactive
protected void connectionSuspended()
public final void resume_connection() throws NotConnected, ConnectionAlreadyActive
NotConnected
ConnectionAlreadyActive
protected void connectionResumed()
protected void checkIsConnected() throws NotConnected
NotConnected
protected void checkIsNotConnected() throws AlreadyConnected
AlreadyConnected
protected void checkStillConnected() throws Disconnected
Disconnected
protected void connectClient(Object client)
protected abstract void disconnectClient()
protected void handleDisconnected(Disconnected e)
protected abstract void removeListener()
public final java.lang.String getJMXObjectName()
getJMXObjectName
in interface JMXManageable
public final java.lang.String getMBeanName()
protected java.lang.String getMBeanType()
public java.lang.String[] getJMXNotificationTypes()
getJMXNotificationTypes
in interface JMXManageable
public void setJMXCallback(JMXManageable.JMXCallback callback)
setJMXCallback
in interface JMXManageable
protected void sendNotification(java.lang.String type, java.lang.String message)
protected void sendNotification(java.lang.String type, java.lang.String message, java.lang.Object payload)
public java.lang.String getStatus()
getStatus
in interface AbstractProxyMBean
public java.lang.String getClientIOR()
getClientIOR
in interface AbstractProxyMBean
public java.lang.String getInterFilterGroupOperator()
getInterFilterGroupOperator
in interface AbstractProxyMBean
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |