public abstract class AbstractProxySubscriber extends Object implements ProxySubscriber, Prioritized
Implementing Prioritized even when Priority is not used is always OK. The default value of 0 retains the FIFO order.
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
veto |
| Modifier | Constructor and Description |
|---|---|
protected |
AbstractProxySubscriber(Object proxiedSubscriber,
Method subscriptionMethod,
ReferenceStrength referenceStrength,
EventService es,
boolean veto) |
protected |
AbstractProxySubscriber(Object proxiedSubscriber,
Method subscriptionMethod,
ReferenceStrength referenceStrength,
int priority,
EventService es,
boolean veto) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object obj) |
EventService |
getEventService() |
int |
getPriority() |
Object |
getProxiedSubscriber() |
ReferenceStrength |
getReferenceStrength() |
Method |
getSubscriptionMethod() |
int |
hashCode() |
void |
proxyUnsubscribed()
Called by EventServices to inform the proxy that it is unsubscribed.
|
protected boolean |
retryReflectiveCallUsingAccessibleObject(Object[] args,
Method subscriptionMethod,
Object obj,
IllegalAccessException e,
String message) |
String |
toString() |
protected AbstractProxySubscriber(Object proxiedSubscriber, Method subscriptionMethod, ReferenceStrength referenceStrength, EventService es, boolean veto)
protected AbstractProxySubscriber(Object proxiedSubscriber, Method subscriptionMethod, ReferenceStrength referenceStrength, int priority, EventService es, boolean veto)
public Object getProxiedSubscriber()
getProxiedSubscriber in interface ProxySubscriberpublic Method getSubscriptionMethod()
public EventService getEventService()
public ReferenceStrength getReferenceStrength()
getReferenceStrength in interface ProxySubscriberpublic int getPriority()
getPriority in interface Prioritizedpublic void proxyUnsubscribed()
Overriding classes must call super.proxyUnsubscribed() or risk things not being cleanup up properly.
proxyUnsubscribed in interface ProxySubscriberprotected boolean retryReflectiveCallUsingAccessibleObject(Object[] args, Method subscriptionMethod, Object obj, IllegalAccessException e, String message)
Copyright © 2013 Bushe Enterprises, Inc.. All Rights Reserved.