|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.servant.AbstractProxy
Field Summary | |
---|---|
protected java.lang.Integer |
id_
|
protected boolean |
isIDPublic_
|
protected MappingFilter |
lifetimeFilter_
|
protected org.apache.avalon.framework.logger.Logger |
logger_
|
protected OfferManager |
offerManager_
|
protected MappingFilter |
priorityFilter_
|
protected QoSPropertySet |
qosSettings_
|
protected SubscriptionManager |
subscriptionManager_
|
protected Servant |
thisServant_
|
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 | |
---|---|
POA |
_default_POA()
Override this method from the Servant baseclass. |
int |
add_filter(Filter filter)
|
void |
addDisposeHook(Disposable d)
|
protected void |
checkDestroyStatus()
|
protected void |
checkIsConnected()
|
protected void |
checkIsNotConnected()
|
protected void |
checkStillConnected()
|
void |
configure(org.apache.avalon.framework.configuration.Configuration conf)
|
protected void |
connectClient(Object client)
|
protected void |
connectionResumed()
this is an extension point. |
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()
|
int |
getErrorCounter()
|
java.util.List |
getFilters()
get Filters associated to this FilterStage. |
java.lang.Integer |
getID()
|
MappingFilter |
getLifetimeFilter()
access the LifetimeFilter attached to this FilterStage |
protected ORB |
getORB()
|
protected POA |
getPOA()
|
MappingFilter |
getPriorityFilter()
access the PriorityFilter attached to this FilterStage |
protected abstract Servant |
getServant()
|
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 |
isConnected()
|
boolean |
isDisposed()
check if this FilterStage has been disposed. |
boolean |
isIDPublic()
|
protected boolean |
isSuspended()
|
MappingFilter |
lifetime_filter()
|
void |
lifetime_filter(MappingFilter filter)
|
abstract ProxyType |
MyType()
|
MappingFilter |
priority_filter()
|
void |
priority_filter(MappingFilter filter)
|
void |
remove_all_filters()
|
void |
remove_filter(int n)
|
protected abstract void |
removeListener()
|
void |
resetErrorCounter()
|
void |
resume_connection()
|
void |
set_qos(Property[] qosProps)
|
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.servant.ManageableServant |
---|
activate |
Field Detail |
protected final boolean isIDPublic_
protected final org.apache.avalon.framework.logger.Logger logger_
protected final QoSPropertySet qosSettings_
protected final java.lang.Integer id_
protected final OfferManager offerManager_
protected final SubscriptionManager subscriptionManager_
protected Servant thisServant_
protected MappingFilter lifetimeFilter_
protected MappingFilter priorityFilter_
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 addDisposeHook(Disposable d)
public boolean isIDPublic()
protected POA getPOA()
protected ORB getORB()
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 POA _default_POA()
public final java.util.List getFilters()
FilterStage
getFilters
in interface FilterStage
public final void deactivate()
deactivate
in interface ManageableServant
public final boolean isDisposed()
FilterStage
isDisposed
in interface FilterStage
protected void checkDestroyStatus() throws OBJECT_NOT_EXIST
OBJECT_NOT_EXIST
public final void destroy()
public void dispose()
dispose
in interface org.picocontainer.Disposable
public abstract ProxyType MyType()
public final boolean hasInterFilterGroupOperatorOR()
FilterStage
hasInterFilterGroupOperatorOR
in interface FilterStage
public final boolean isConnected()
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()
public final int getErrorCounter()
public final int incErrorCounter()
protected 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 abstract Servant getServant()
protected void handleDisconnected(Disconnected e)
protected abstract void removeListener()
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |