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 ProxySubscriber
public Method getSubscriptionMethod()
public EventService getEventService()
public ReferenceStrength getReferenceStrength()
getReferenceStrength
in interface ProxySubscriber
public int getPriority()
getPriority
in interface Prioritized
public void proxyUnsubscribed()
Overriding classes must call super.proxyUnsubscribed() or risk things not being cleanup up properly.
proxyUnsubscribed
in interface ProxySubscriber
protected boolean retryReflectiveCallUsingAccessibleObject(Object[] args, Method subscriptionMethod, Object obj, IllegalAccessException e, String message)
Copyright © 2013 Bushe Enterprises, Inc.. All rights reserved.