org.jacorb.notification.servant

Class AbstractProxy

Implemented Interfaces:
Configurable, Disposable, FilterAdminOperations, FilterStage, ManageableServant, QoSAdminOperations
Known Direct Subclasses:
AbstractProxySupplier

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

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

Author:
Alphonse Bendt

Field Summary

protected AbstractAdmin
admin_
protected ChannelContext
channelContext_
protected Integer
id_
protected boolean
isIDPublic_
protected MappingFilter
lifetimeFilter_
protected Logger
logger_
protected OfferManager
offerManager_
protected MappingFilter
priorityFilter_
protected QoSPropertySet
qosSettings_
protected SubscriptionManager
subscriptionManager_
protected Servant
thisServant_

Method Summary

ProxyType
MyType()
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(Configuration conf)
protected void
connectClient(Object client)
protected void
connectionResumed()
invoked when resume_connection was called successfully.
protected void
connectionSuspended()
void
deactivate()
protected void
disconnectClient()
invoke the proxy specific disconnect method.
void
dispose()
Dispose this Object.
int
getErrorCounter()
List
getFilters()
get Filters associated to this FilterStage.
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()
int[]
get_all_filters()
Filter
get_filter(int n)
Property[]
get_qos()
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)
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
setDisposeHook(Runnable hook)
void
setID(Integer id, boolean isIDPublic)
void
setORB(ORB orb)
void
setOfferManager(OfferManager m)
void
setPOA(POA poa)
void
setSubscriptionManager(SubscriptionManager m)
void
setTaskProcessor(TaskProcessor tp)
void
set_qos(Property qosProps)
void
suspend_connection()
void
validate_event_qos(Property qosProps, NamedPropertyRangeSeqHolder propSeqHolder)
void
validate_qos(Property props, NamedPropertyRangeSeqHolder propertyRange)

Field Details

admin_

protected AbstractAdmin admin_


channelContext_

protected ChannelContext channelContext_


id_

protected Integer id_


isIDPublic_

protected boolean isIDPublic_


lifetimeFilter_

protected MappingFilter lifetimeFilter_


logger_

protected Logger logger_


offerManager_

protected OfferManager offerManager_


priorityFilter_

protected MappingFilter priorityFilter_


qosSettings_

protected QoSPropertySet qosSettings_


subscriptionManager_

protected SubscriptionManager subscriptionManager_


thisServant_

protected Servant thisServant_

Method Details

MyType

public ProxyType MyType()


_default_POA

public final POA _default_POA()
Override this method from the Servant baseclass. Fintan Bolton in his book "Pure CORBA" suggests that you override this method to avoid the risk that a servant object (like this one) could be activated by the wrong POA object.


add_filter

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


assertConnected

protected void assertConnected()
            throws NotConnected


assertNotConnected

protected void assertNotConnected()
            throws AlreadyConnected


checkStillConnected

protected void checkStillConnected()
            throws Disconnected


configure

public void configure(Configuration conf)


connectClient

protected void connectClient(Object client)


connectionResumed

protected void connectionResumed()
invoked when resume_connection was called successfully.


connectionSuspended

protected void connectionSuspended()


deactivate

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


disconnectClient

protected void disconnectClient()
invoke the proxy specific disconnect method.


dispose

public void dispose()
Dispose this Object. Free all associated Ressources allocated by this Object. The Object may not be used after a call to dispose.
Specified by:
dispose in interface Disposable


getErrorCounter

public int getErrorCounter()


getFilters

public List getFilters()
get Filters associated to this FilterStage.
Specified by:
getFilters in interface FilterStage


getID

public Integer getID()


getLifetimeFilter

public MappingFilter getLifetimeFilter()
access the LifetimeFilter attached to this FilterStage
Specified by:
getLifetimeFilter in interface FilterStage

Returns:
a LifetimeFilter or null if no Filter is attached


getORB

protected ORB getORB()


getPOA

protected POA getPOA()


getPriorityFilter

public MappingFilter getPriorityFilter()
access the PriorityFilter attached to this FilterStage
Specified by:
getPriorityFilter in interface FilterStage

Returns:
a PriorityFilter or null if no Filter is attached


getTaskProcessor

protected TaskProcessor getTaskProcessor()


get_all_filters

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


get_filter

public Filter get_filter(int n)
            throws FilterNotFound
Specified by:
get_filter in interface FilterAdminOperations


get_qos

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


handleDisconnected

protected void handleDisconnected(Disconnected e)


hasInterFilterGroupOperatorOR

public boolean hasInterFilterGroupOperatorOR()
check if this FilterStage has OR Semantic enabled.
Specified by:
hasInterFilterGroupOperatorOR in interface FilterStage


hasLifetimeFilter

public boolean hasLifetimeFilter()
check if this FilterStage has a LifetimeFilter attached
Specified by:
hasLifetimeFilter in interface FilterStage


hasPriorityFilter

public boolean hasPriorityFilter()
check if this FilterStage has a PriorityFilter attached
Specified by:
hasPriorityFilter in interface FilterStage


incErrorCounter

public int incErrorCounter()


isConnected

public boolean isConnected()


isDisposed

public boolean isDisposed()
check if this FilterStage has been disposed.
Specified by:
isDisposed in interface FilterStage


isIDPublic

public boolean isIDPublic()


isSuspended

protected boolean isSuspended()


lifetime_filter

public MappingFilter lifetime_filter()


lifetime_filter

public void lifetime_filter(MappingFilter filter)


preActivate

public void preActivate()
            throws Exception
Specified by:
preActivate in interface ManageableServant


priority_filter

public MappingFilter priority_filter()


priority_filter

public void priority_filter(MappingFilter filter)


remove_all_filters

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


remove_filter

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


resetErrorCounter

public void resetErrorCounter()


resume_connection

public final void resume_connection()
            throws NotConnected,
                   ConnectionAlreadyActive


setDisposeHook

public void setDisposeHook(Runnable hook)


setID

public void setID(Integer id,
                  boolean isIDPublic)


setORB

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


setOfferManager

public void setOfferManager(OfferManager m)


setPOA

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


setSubscriptionManager

public void setSubscriptionManager(SubscriptionManager m)


setTaskProcessor

public void setTaskProcessor(TaskProcessor tp)


set_qos

public void set_qos(Property qosProps)
            throws UnsupportedQoS


suspend_connection

public final void suspend_connection()
            throws NotConnected,
                   ConnectionAlreadyInactive


validate_event_qos

public void validate_event_qos(Property qosProps,
                               NamedPropertyRangeSeqHolder propSeqHolder)
            throws UnsupportedQoS


validate_qos

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