org.jacorb.notification.servant

Class AbstractProxy

public abstract class AbstractProxy extends Object implements FilterAdminOperations, QoSAdminOperations, FilterStage, IServantLifecyle, Configurable, JMXManageable, AbstractProxyMBean

Version: $Id: AbstractProxy.java,v 1.31 2006/03/06 19:53:46 alphonse.bendt Exp $

Author: Alphonse Bendt

UNKNOWN:

Field Summary
protected Configurationconfig_
protected SeteventTypes_
protected Loggerlogger_
protected OfferManagerofferManager_
protected QoSPropertySetqosSettings_
protected SubscriptionManagersubscriptionManager_
Constructor Summary
protected AbstractProxy(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager)
Method Summary
Objectactivate()
intadd_filter(Filter filter)
protected voidcheckDestroyStatus()
protected voidcheckIsConnected()
protected voidcheckIsNotConnected()
protected voidcheckStillConnected()
protected abstract voidclientDisconnected()
voidconfigure(Configuration conf)
protected voidconnectClient(Object client)
protected voidconnectionResumed()
this is an extension point. invoked when resume_connection was called successfully.
protected voidconnectionSuspended()
this is an extension point.
voiddeactivate()
voiddestroy()
protected abstract voiddisconnectClient()
invoke the proxy specific disconnect method.
voiddispose()
StringgetClientIOR()
booleangetConnected()
intgetErrorCounter()
ListgetFilters()
IntegergetID()
StringgetInterFilterGroupOperator()
String[]getJMXNotificationTypes()
StringgetJMXObjectName()
MappingFiltergetLifetimeFilter()
StringgetMBeanName()
protected StringgetMBeanType()
protected ORBgetORB()
POAgetPOA()
MappingFiltergetPriorityFilter()
StringgetStatus()
protected TaskProcessorgetTaskProcessor()
int[]get_all_filters()
Filterget_filter(int n)
Property[]get_qos()
protected voidhandleDisconnected(Disconnected e)
booleanhasInterFilterGroupOperatorOR()
booleanhasLifetimeFilter()
booleanhasPriorityFilter()
intincErrorCounter()
booleanisDestroyed()
booleanisIDPublic()
booleanisSuspended()
MappingFilterlifetime_filter()
voidlifetime_filter(MappingFilter filter)
abstract ProxyTypeMyType()
voidpriority_filter(MappingFilter filter)
MappingFilterpriority_filter()
voidregisterDisposable(Disposable d)
protected abstract voidremoveListener()
voidremove_all_filters()
voidremove_filter(int n)
voidresetErrorCounter()
voidresume_connection()
protected voidsendNotification(String type, String message)
protected voidsendNotification(String type, String message, Object payload)
voidsetJMXCallback(JMXManageable.JMXCallback callback)
voidset_qos(Property[] qosProps)
voidsuspend_connection()
voidvalidate_event_qos(Property[] qosProps, NamedPropertyRangeSeqHolder propSeqHolder)
voidvalidate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRange)

Field Detail

config_

protected Configuration config_

eventTypes_

protected final Set eventTypes_

logger_

protected final Logger logger_

offerManager_

protected final OfferManager offerManager_

qosSettings_

protected final QoSPropertySet qosSettings_

subscriptionManager_

protected final SubscriptionManager subscriptionManager_

Constructor Detail

AbstractProxy

protected AbstractProxy(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager)

Method Detail

activate

public final Object activate()

add_filter

public final int add_filter(Filter filter)

checkDestroyStatus

protected void checkDestroyStatus()

checkIsConnected

protected void checkIsConnected()

checkIsNotConnected

protected void checkIsNotConnected()

checkStillConnected

protected void checkStillConnected()

clientDisconnected

protected abstract void clientDisconnected()

configure

public void configure(Configuration conf)

connectClient

protected void connectClient(Object client)

connectionResumed

protected void connectionResumed()
this is an extension point. invoked when resume_connection was called successfully.

connectionSuspended

protected void connectionSuspended()
this is an extension point.

deactivate

public final void deactivate()

destroy

public final void destroy()

UNKNOWN: description = "Destroy this Proxy" impact = "ACTION"

disconnectClient

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

dispose

public void dispose()

getClientIOR

public String getClientIOR()

UNKNOWN: description = "IOR of the connected client" access = "read-only"

getConnected

public final boolean getConnected()

UNKNOWN: description = "Connection Status." access = "read-only"

getErrorCounter

public final int getErrorCounter()

UNKNOWN: description = "error counter" access = "read-only"

getFilters

public final List getFilters()

getID

public final Integer getID()

getInterFilterGroupOperator

public String getInterFilterGroupOperator()

UNKNOWN: description = "InterFilterGroupOperator used for this proxy" access = "read-only" currencyTimeLimit = "2147483647"

getJMXNotificationTypes

public String[] getJMXNotificationTypes()

getJMXObjectName

public final String getJMXObjectName()

getLifetimeFilter

public final MappingFilter getLifetimeFilter()

getMBeanName

public final String getMBeanName()

getMBeanType

protected String getMBeanType()

getORB

protected ORB getORB()

getPOA

public final POA getPOA()

getPriorityFilter

public final MappingFilter getPriorityFilter()

getStatus

public String getStatus()

UNKNOWN: description = "current Status for this Proxy (NOT CONNECTED|ACTIVE|SUSPENDED|DESTROYED)" access = "read-only"

getTaskProcessor

protected TaskProcessor getTaskProcessor()

get_all_filters

public final int[] get_all_filters()

get_filter

public final Filter get_filter(int n)

get_qos

public final Property[] get_qos()

handleDisconnected

protected void handleDisconnected(Disconnected e)

hasInterFilterGroupOperatorOR

public final boolean hasInterFilterGroupOperatorOR()

hasLifetimeFilter

public final boolean hasLifetimeFilter()

hasPriorityFilter

public final boolean hasPriorityFilter()

incErrorCounter

public final int incErrorCounter()

isDestroyed

public final boolean isDestroyed()

isIDPublic

public boolean isIDPublic()

isSuspended

public boolean isSuspended()

lifetime_filter

public final MappingFilter lifetime_filter()

lifetime_filter

public final void lifetime_filter(MappingFilter filter)

MyType

public abstract ProxyType MyType()

priority_filter

public final void priority_filter(MappingFilter filter)

priority_filter

public final MappingFilter priority_filter()

registerDisposable

public void registerDisposable(Disposable d)

removeListener

protected abstract void removeListener()

remove_all_filters

public final void remove_all_filters()

remove_filter

public final void remove_filter(int n)

resetErrorCounter

public void resetErrorCounter()

UNKNOWN: impact = "ACTION" description = "reset the error counter to its initial value"

resume_connection

public final void resume_connection()

sendNotification

protected void sendNotification(String type, String message)

sendNotification

protected void sendNotification(String type, String message, Object payload)

setJMXCallback

public void setJMXCallback(JMXManageable.JMXCallback callback)

set_qos

public final void set_qos(Property[] qosProps)

suspend_connection

public final void suspend_connection()

validate_event_qos

public void validate_event_qos(Property[] qosProps, NamedPropertyRangeSeqHolder propSeqHolder)

validate_qos

public final void validate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRange)