|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.ra.DefaultMuleConnection
MuleConnection
TODO
Constructor Summary | |
DefaultMuleConnection(MuleManagedConnection managedConnection,
UMOManager manager,
MuleCredentials credentials)
|
Method Summary | |
void |
associateConnection(MuleManagedConnection newMc)
Associates connection handle with new managed connection. |
void |
close()
Closes the connection. |
void |
dispatch(java.lang.String url,
java.lang.Object payload,
java.util.Map messageProperties)
Dispatches an event asynchronously to a endpointUri via a mule server. |
protected UMOEvent |
getEvent(UMOMessage message,
UMOEndpointURI uri,
boolean synchronous)
Packages a mule event for the current request |
MuleManagedConnection |
getManagedConnection()
Retrieves a ManagedConnection. |
UMOMessage |
receive(java.lang.String url,
long timeout)
Will receive an event from an endpointUri determined by the url |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public DefaultMuleConnection(MuleManagedConnection managedConnection, UMOManager manager, MuleCredentials credentials)
Method Detail |
public void dispatch(java.lang.String url, java.lang.Object payload, java.util.Map messageProperties) throws UMOException
dispatch
in interface MuleConnection
url
- the Mule url used to determine the destination and transport of the messagepayload
- the object that is the payload of the eventmessageProperties
- any properties to be associated with the payload. In the case of Jms you could
set the JMSReplyTo property in these properties.
UMOException
public UMOMessage receive(java.lang.String url, long timeout) throws UMOException
receive
in interface MuleConnection
url
- the Mule url used to determine the destination and transport of the messagetimeout
- how long to block waiting to receive the event, if set to 0 the receive will
not wait at all and if set to -1 the receive will wait forever
UMOException
protected UMOEvent getEvent(UMOMessage message, UMOEndpointURI uri, boolean synchronous) throws UMOException
message
- the event payloaduri
- the destination endpointUrisynchronous
- whether the event will be synchronously processed
UMOException
public MuleManagedConnection getManagedConnection()
getManagedConnection
in interface MuleConnection
public void close() throws ResourceException
close
in interface MuleConnection
ResourceException
public void associateConnection(MuleManagedConnection newMc) throws ResourceException
associateConnection
in interface MuleConnection
newMc
- new managed connection
ResourceException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |