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"