org.jacorb.notification.servant
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 $
UNKNOWN:
| Field Summary | |
|---|---|
| protected Configuration | config_ |
| protected Set | eventTypes_ |
| protected Logger | logger_ |
| protected OfferManager | offerManager_ |
| protected QoSPropertySet | qosSettings_ |
| protected SubscriptionManager | subscriptionManager_ |
| Constructor Summary | |
|---|---|
| protected | AbstractProxy(IAdmin admin, ORB orb, POA poa, 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(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() |
| String | getClientIOR() |
| boolean | getConnected() |
| int | getErrorCounter() |
| List | getFilters() |
| Integer | getID() |
| String | getInterFilterGroupOperator() |
| String[] | getJMXNotificationTypes() |
| String | getJMXObjectName() |
| MappingFilter | getLifetimeFilter() |
| String | getMBeanName() |
| protected String | getMBeanType() |
| protected ORB | getORB() |
| POA | getPOA() |
| MappingFilter | getPriorityFilter() |
| String | getStatus() |
| protected TaskProcessor | getTaskProcessor() |
| int[] | get_all_filters() |
| Filter | get_filter(int n) |
| Property[] | get_qos() |
| protected void | handleDisconnected(Disconnected e) |
| boolean | hasInterFilterGroupOperatorOR() |
| boolean | hasLifetimeFilter() |
| boolean | hasPriorityFilter() |
| int | incErrorCounter() |
| boolean | isDestroyed() |
| boolean | isIDPublic() |
| boolean | isSuspended() |
| MappingFilter | lifetime_filter() |
| void | lifetime_filter(MappingFilter filter) |
| abstract ProxyType | MyType() |
| void | priority_filter(MappingFilter filter) |
| MappingFilter | priority_filter() |
| void | registerDisposable(Disposable d) |
| protected abstract void | removeListener() |
| void | remove_all_filters() |
| void | remove_filter(int n) |
| void | resetErrorCounter() |
| void | resume_connection() |
| protected void | sendNotification(String type, String message) |
| protected void | sendNotification(String type, String message, Object payload) |
| void | setJMXCallback(JMXManageable.JMXCallback callback) |
| void | set_qos(Property[] qosProps) |
| void | suspend_connection() |
| void | validate_event_qos(Property[] qosProps, NamedPropertyRangeSeqHolder propSeqHolder) |
| void | validate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRange) |
UNKNOWN: description = "Destroy this Proxy" impact = "ACTION"
UNKNOWN: description = "IOR of the connected client" access = "read-only"
UNKNOWN: description = "Connection Status." access = "read-only"
UNKNOWN: description = "error counter" access = "read-only"
UNKNOWN: description = "InterFilterGroupOperator used for this proxy" access = "read-only" currencyTimeLimit = "2147483647"
UNKNOWN: description = "current Status for this Proxy (NOT CONNECTED|ACTIVE|SUSPENDED|DESTROYED)" access = "read-only"
UNKNOWN: impact = "ACTION" description = "reset the error counter to its initial value"