|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.servant.AbstractProxy
public abstract class AbstractProxy
Field Summary | |
---|---|
protected AbstractAdmin |
admin_
|
protected ChannelContext |
channelContext_
|
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_
|
Method Summary | |
---|---|
POA |
_default_POA()
Override this method from the Servant baseclass. |
int |
add_filter(Filter filter)
|
protected void |
assertConnected()
|
protected void |
assertNotConnected()
|
protected void |
checkStillConnected()
|
void |
configure(org.apache.avalon.framework.configuration.Configuration conf)
|
protected void |
connectClient(Object client)
|
protected void |
connectionResumed()
invoked when resume_connection was called successfully. |
protected void |
connectionSuspended()
|
void |
deactivate()
|
protected abstract void |
disconnectClient()
invoke the proxy specific disconnect method. |
void |
dispose()
Dispose this Object. |
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 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()
|
void |
preActivate()
|
MappingFilter |
priority_filter()
|
void |
priority_filter(MappingFilter filter)
|
void |
remove_all_filters()
|
void |
remove_filter(int n)
|
void |
resetErrorCounter()
|
void |
resume_connection()
|
void |
set_qos(Property[] qosProps)
|
void |
setDisposeHook(java.lang.Runnable hook)
|
void |
setID(java.lang.Integer id,
boolean isIDPublic)
|
void |
setOfferManager(OfferManager m)
|
void |
setORB(ORB orb)
|
void |
setPOA(POA poa)
|
void |
setSubscriptionManager(SubscriptionManager m)
|
void |
setTaskProcessor(TaskProcessor tp)
|
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, getSubsequentFilterStages, hasMessageConsumer |
Methods inherited from interface org.jacorb.notification.servant.ManageableServant |
---|
activate |
Field Detail |
---|
protected boolean isIDPublic_
protected org.apache.avalon.framework.logger.Logger logger_
protected QoSPropertySet qosSettings_
protected java.lang.Integer id_
protected AbstractAdmin admin_
protected OfferManager offerManager_
protected SubscriptionManager subscriptionManager_
protected Servant thisServant_
protected MappingFilter lifetimeFilter_
protected MappingFilter priorityFilter_
protected ChannelContext channelContext_
Method Detail |
---|
public void configure(org.apache.avalon.framework.configuration.Configuration conf)
configure
in interface org.apache.avalon.framework.configuration.Configurable
public void setOfferManager(OfferManager m)
public void setSubscriptionManager(SubscriptionManager m)
public void setDisposeHook(java.lang.Runnable hook)
public void setID(java.lang.Integer id, boolean isIDPublic)
public boolean isIDPublic()
public void setPOA(POA poa)
setPOA
in interface ManageableServant
protected POA getPOA()
public void setORB(ORB orb)
setORB
in interface ManageableServant
protected ORB getORB()
public void setTaskProcessor(TaskProcessor tp)
protected TaskProcessor getTaskProcessor()
public int add_filter(Filter filter)
add_filter
in interface FilterAdminOperations
public void remove_filter(int n) throws FilterNotFound
remove_filter
in interface FilterAdminOperations
FilterNotFound
public Filter get_filter(int n) 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 void validate_event_qos(Property[] qosProps, NamedPropertyRangeSeqHolder propSeqHolder) throws UnsupportedQoS
UnsupportedQoS
public void validate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRange) throws UnsupportedQoS
validate_qos
in interface QoSAdminOperations
UnsupportedQoS
public void set_qos(Property[] qosProps) throws UnsupportedQoS
set_qos
in interface QoSAdminOperations
UnsupportedQoS
public Property[] get_qos()
get_qos
in interface QoSAdminOperations
public void priority_filter(MappingFilter filter)
public MappingFilter priority_filter()
public MappingFilter lifetime_filter()
public void lifetime_filter(MappingFilter filter)
public java.lang.Integer getID()
public final POA _default_POA()
public java.util.List getFilters()
FilterStage
getFilters
in interface FilterStage
public void deactivate()
deactivate
in interface ManageableServant
public boolean isDisposed()
FilterStage
isDisposed
in interface FilterStage
public void dispose()
Disposable
dispose
in interface Disposable
public abstract ProxyType MyType()
public boolean hasInterFilterGroupOperatorOR()
FilterStage
hasInterFilterGroupOperatorOR
in interface FilterStage
public boolean isConnected()
public boolean hasLifetimeFilter()
FilterStage
hasLifetimeFilter
in interface FilterStage
public boolean hasPriorityFilter()
FilterStage
hasPriorityFilter
in interface FilterStage
public MappingFilter getLifetimeFilter()
FilterStage
getLifetimeFilter
in interface FilterStage
public MappingFilter getPriorityFilter()
FilterStage
getPriorityFilter
in interface FilterStage
public void resetErrorCounter()
public int getErrorCounter()
public 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 assertConnected() throws NotConnected
NotConnected
protected void assertNotConnected() throws AlreadyConnected
AlreadyConnected
protected void checkStillConnected() throws Disconnected
Disconnected
protected void connectClient(Object client)
public void preActivate() throws java.lang.Exception
preActivate
in interface ManageableServant
java.lang.Exception
protected abstract void disconnectClient()
protected void handleDisconnected(Disconnected e)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |