|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.mule.extras.client.RemoteDispatcher
RemoteDispatcher is used to make and receive requests to a remote
Mule instance. It is used to proxy requests to Mule using the Server Url as the
the transport channel.
| Field Summary | |
protected static Log |
logger
logger used by this class |
| Constructor Summary | |
protected |
RemoteDispatcher(String endpoint)
|
protected |
RemoteDispatcher(String endpoint,
UMOCredentials credentials)
|
| Method Summary | |
FutureMessageResult |
asyncReceiveRemote(String endpoint,
int timeout)
|
protected UMOMessage |
dispatchAction(AdminNotification action,
boolean synchronous,
int timeout)
|
void |
dispatchRemote(String endpoint,
Object payload,
Map messageProperties)
|
void |
dispatchToRemoteComponent(String component,
Object payload,
Map messageProperties)
Dispatcher an event asynchronously to a components on a remote Mule instance. |
void |
dispose()
A lifecycle method where implementor should free up any resources. |
protected UMOMessage |
doToRemote(String endpoint,
Object payload,
Map messageProperties,
boolean synchronous,
int timeout)
|
protected UMOMessage |
doToRemoteComponent(String component,
Object payload,
Map messageProperties,
boolean synchronous)
|
WireFormat |
getWireFormat()
|
UMOMessage |
receiveRemote(String endpoint,
int timeout)
|
FutureMessageResult |
sendAsyncRemote(String endpoint,
Object payload,
Map messageProperties)
|
FutureMessageResult |
sendAsyncToRemoteComponent(String component,
String transformers,
Object payload,
Map messageProperties)
sends an event to a components on a remote Mule instance, while making the result of the event trigger available as a Future result that can be accessed later by client code. |
UMOMessage |
sendRemote(String endpoint,
Object payload,
Map messageProperties)
|
UMOMessage |
sendRemote(String endpoint,
Object payload,
Map messageProperties,
int timeout)
|
UMOMessage |
sendToRemoteComponent(String component,
Object payload,
Map messageProperties)
sends an event synchronously to a components on a remote Mule instance. |
protected void |
setCredentials(UMOMessage message)
|
protected void |
setExecutorService(ExecutorService e)
|
void |
setWireFormat(WireFormat wireFormat)
|
protected void |
updateContext(UMOMessage message,
UMOEndpoint endpoint,
boolean synchronous)
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
protected static Log logger
| Constructor Detail |
protected RemoteDispatcher(String endpoint,
UMOCredentials credentials)
throws UMOException
protected RemoteDispatcher(String endpoint)
throws UMOException
| Method Detail |
protected void setExecutorService(ExecutorService e)
public void dispatchToRemoteComponent(String component,
Object payload,
Map messageProperties)
throws UMOException
component - the name of the Mule components to dispatch topayload - the object that is the payload of the eventmessageProperties - any properties to be associated with the payload. as
null
UMOException - if the dispatch fails or the components or
transfromers cannot be found
public UMOMessage sendToRemoteComponent(String component,
Object payload,
Map messageProperties)
throws UMOException
component - the name of the Mule components to send topayload - the object that is the payload of the eventmessageProperties - any properties to be associated with the payload. as
null
UMOException - if the dispatch fails or the components or
transfromers cannot be found
public FutureMessageResult sendAsyncToRemoteComponent(String component,
String transformers,
Object payload,
Map messageProperties)
throws UMOException
component - the name of the Mule components to send totransformers - a comma separated list of transformers to apply to the
result messagepayload - the object that is the payload of the eventmessageProperties - any properties to be associated with the payload. as
null
UMOException - if the dispatch fails or the components or
transfromers cannot be found
public UMOMessage sendRemote(String endpoint,
Object payload,
Map messageProperties,
int timeout)
throws UMOException
UMOException
public UMOMessage sendRemote(String endpoint,
Object payload,
Map messageProperties)
throws UMOException
UMOException
public void dispatchRemote(String endpoint,
Object payload,
Map messageProperties)
throws UMOException
UMOException
public FutureMessageResult sendAsyncRemote(String endpoint,
Object payload,
Map messageProperties)
throws UMOException
UMOException
public UMOMessage receiveRemote(String endpoint,
int timeout)
throws UMOException
UMOException
public FutureMessageResult asyncReceiveRemote(String endpoint,
int timeout)
throws UMOException
UMOException
protected UMOMessage doToRemoteComponent(String component,
Object payload,
Map messageProperties,
boolean synchronous)
throws UMOException
UMOException
protected UMOMessage doToRemote(String endpoint,
Object payload,
Map messageProperties,
boolean synchronous,
int timeout)
throws UMOException
UMOException
protected UMOMessage dispatchAction(AdminNotification action,
boolean synchronous,
int timeout)
throws UMOException
UMOExceptionpublic void dispose()
Disposable
dispose in interface Disposableprotected void setCredentials(UMOMessage message)
public WireFormat getWireFormat()
public void setWireFormat(WireFormat wireFormat)
protected void updateContext(UMOMessage message,
UMOEndpoint endpoint,
boolean synchronous)
throws UMOException
UMOException
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||