|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.impl.MuleProxy
MuleProxy
is a proxy to a UMO. It is a poolable object that
that can be executed in it's own thread.
Constructor Summary | |
MuleProxy(java.lang.Object component,
MuleDescriptor descriptor,
ObjectPool proxyPool)
Constructs a Proxy using the UMO's AbstractMessageDispatcher and the UMO itself |
Method Summary | |
void |
dispose()
A lifecycle method where implementor should fee up any resources If an exception is thrown it should just be logged and processing should continue. |
UMOImmutableDescriptor |
getDescriptor()
|
ComponentStatistics |
getStatistics()
|
void |
handleException(java.lang.Exception exception)
When an exception occurs this method can be called to invoke the configured UMOExceptionStrategy on the UMO |
boolean |
isStarted()
|
boolean |
isSuspended()
Determines if the proxy is suspended |
java.lang.Object |
onCall(UMOEvent event)
Makes a synchronous call on the UMO |
void |
onEvent(UMOEvent event)
Sets the current event being processed |
protected UMOMessage |
processResponse(UMOMessage message,
java.lang.Object replyTo,
ReplyToHandler replyToHandler)
|
void |
release()
|
void |
resume()
Triggers the UMO to resume processing of events if it is suspended |
void |
run()
|
void |
setStatistics(ComponentStatistics stat)
|
void |
start()
|
void |
stop()
|
void |
suspend()
Controls the suspension of the UMO event processing |
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public MuleProxy(java.lang.Object component, MuleDescriptor descriptor, ObjectPool proxyPool) throws UMOException
component
- the underlying object that with receive eventsdescriptor
- the UMOComponent descriptor associated with the componentMethod Detail |
public void start() throws UMOException
start
in interface Startable
UMOException
public boolean isStarted()
public void stop() throws UMOException
stop
in interface Stoppable
UMOException
public void dispose()
Disposable
dispose
in interface Disposable
public void onEvent(UMOEvent event)
event
- the event being processedpublic ComponentStatistics getStatistics()
public void setStatistics(ComponentStatistics stat)
public java.lang.Object onCall(UMOEvent event) throws UMOException
event
- the event to pass to the UMO
UMOException
- if the call failsprotected UMOMessage processResponse(UMOMessage message, java.lang.Object replyTo, ReplyToHandler replyToHandler) throws UMOException
UMOException
public void handleException(java.lang.Exception exception)
exception
- If the UMOExceptionStrategy implementation failspublic java.lang.String toString()
public boolean isSuspended()
public void suspend()
public void resume()
public void run()
public void release()
public UMOImmutableDescriptor getDescriptor()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |