|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
UMOMessageDispatcher is the interface responsible for distpatching
events to a particular transport. It implements the client code necessary to write
data to the underlying protocol. The dispatcher also exposes a receive method that
allows users to make specific calls to the underlying transport to receive an
event.
| Field Summary | |
static long |
RECEIVE_NO_WAIT
|
static long |
RECEIVE_WAIT_INDEFINITELY
|
| Method Summary | |
void |
dispatch(UMOEvent event)
Dispatches an event from the endpoint to the external system |
UMOConnector |
getConnector()
Gets the connector for this dispatcher |
Object |
getDelegateSession()
If the underlying transport has the notion of a client session when writing to it, the session should be obtainable using this method. |
OutputStream |
getOutputStream(UMOImmutableEndpoint endpoint,
UMOMessage message)
Well get the output stream (if any) for this type of transport. |
boolean |
isDisposed()
Determines if this dispatcher has been disposed. |
UMOMessage |
receive(UMOEndpointURI endpointUri,
long timeout)
Deprecated. Use receive(UMOImmutableEndpoint endpoint, long timeout) |
UMOMessage |
receive(UMOImmutableEndpoint endpoint,
long timeout)
Make a specific request to the underlying transport |
UMOMessage |
send(UMOEvent event)
Sends an event from the endpoint to the external system |
| Methods inherited from interface org.mule.umo.lifecycle.Disposable |
dispose |
| Methods inherited from interface org.mule.umo.provider.UMOConnectable |
connect, disconnect, getConnectionDescription, isConnected |
| Field Detail |
public static final long RECEIVE_WAIT_INDEFINITELY
public static final long RECEIVE_NO_WAIT
| Method Detail |
public void dispatch(UMOEvent event)
throws DispatchException
event - The event to dispatch
DispatchException - if the event fails to be dispatched
public UMOMessage send(UMOEvent event)
throws DispatchException
event - The event to send
DispatchException - if the event fails to be dispatched
public UMOMessage receive(UMOEndpointURI endpointUri,
long timeout)
throws Exception
endpointUri - the endpoint URI to use when connecting to the resourcetimeout - the maximum time the operation should block before returning.
The call should return immediately if there is data available. If
no data becomes available before the timeout elapses, null will be
returned
Exception - if the call to the underlying protocal cuases an exception
public UMOMessage receive(UMOImmutableEndpoint endpoint,
long timeout)
throws Exception
endpoint - the endpoint to use when connecting to the resourcetimeout - the maximum time the operation should block before returning.
The call should return immediately if there is data available. If
no data becomes available before the timeout elapses, null will be
returned
Exception - if the call to the underlying protocal cuases an exception
public Object getDelegateSession()
throws UMOException
UMOExceptionpublic UMOConnector getConnector()
public boolean isDisposed()
public OutputStream getOutputStream(UMOImmutableEndpoint endpoint,
UMOMessage message)
throws UMOException
endpoint - the endpoint that releates to this Dispatchermessage - the current message being processed
UMOException
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||