|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.mule.impl.model.DefaultMuleProxy
MuleProxy is a proxy to a UMO. It is a poolable object that that
can be executed in it's own thread.
| Constructor Summary | |
DefaultMuleProxy(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 free up any resources. |
UMOImmutableDescriptor |
getDescriptor()
|
protected ReplyToHandler |
getReplyToHandler(UMOMessage message,
UMOImmutableEndpoint endpoint)
|
ComponentStatistics |
getStatistics()
|
void |
handleException(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 |
Object |
onCall(UMOEvent event)
Makes a synchronous call on the UMO |
void |
onEvent(QueueSession session,
UMOEvent event)
Sets the current event being processed |
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 |
String |
toString()
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Constructor Detail |
public DefaultMuleProxy(Object component,
MuleDescriptor descriptor,
ObjectPool proxyPool)
throws UMOException
component - the underlying object that with receive eventsdescriptor - the UMOComponent descriptor associated with the component| Method Detail |
public void start()
throws UMOException
start in interface StartableUMOExceptionpublic boolean isStarted()
public void stop()
throws UMOException
stop in interface StoppableUMOExceptionpublic void dispose()
Disposable
dispose in interface Disposable
public void onEvent(QueueSession session,
UMOEvent event)
onEvent in interface MuleProxyevent - the event being processedpublic ComponentStatistics getStatistics()
getStatistics in interface MuleProxypublic void setStatistics(ComponentStatistics stat)
setStatistics in interface MuleProxy
public Object onCall(UMOEvent event)
throws UMOException
onCall in interface MuleProxyevent - the event to pass to the UMO
UMOException - if the call failspublic void handleException(Exception exception)
handleException in interface MuleProxyexception - If the UMOExceptionStrategy implementation failspublic String toString()
public boolean isSuspended()
isSuspended in interface MuleProxypublic void suspend()
suspend in interface MuleProxypublic void resume()
resume in interface MuleProxy
protected ReplyToHandler getReplyToHandler(UMOMessage message,
UMOImmutableEndpoint endpoint)
public void run()
public void release()
public UMOImmutableDescriptor getDescriptor()
getDescriptor in interface MuleProxy
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||