|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
UMOConnector is the mechanism used to connect to external systems
and protocols in order to send and receive data.
| Field Summary | |
static int |
INT_VALUE_NOT_SET
|
| Method Summary | |
UMOMessageDispatcher |
getDispatcher(UMOImmutableEndpoint endpoint)
The connector can pool dispatchers based on their endpointUri or can ingnore the endpointUri altogether and use a ThreadLocal or always create new. |
UMOMessageDispatcherFactory |
getDispatcherFactory()
The dispatcher factory is used to create a message dispatcher of the current request |
ExceptionListener |
getExceptionListener()
|
UMOMessageAdapter |
getMessageAdapter(Object message)
Gets a UMOMessageAdapter from the connector for the given
message (data) |
String |
getName()
|
String |
getProtocol()
|
UMOStreamMessageAdapter |
getStreamMessageAdapter(InputStream in,
OutputStream out)
Gets a UMOStreamMessageAdapter from the connector for the given
message. |
void |
handleException(Exception exception)
|
boolean |
isDisposed()
|
boolean |
isDisposing()
|
boolean |
isRemoteSyncEnabled()
|
boolean |
isStarted()
|
UMOMessageReceiver |
registerListener(UMOComponent component,
UMOEndpoint endpoint)
This creates a UMOMessageReceiver associated with this endpoint
and registers it with the connector |
void |
setDispatcherFactory(UMOMessageDispatcherFactory factory)
The dispatcher factory is used to create a message dispatcher of the current request |
void |
setExceptionListener(ExceptionListener listener)
|
void |
setName(String newName)
|
void |
startConnector()
|
void |
stopConnector()
|
boolean |
supportsProtocol(String protocol)
|
void |
unregisterListener(UMOComponent component,
UMOEndpoint endpoint)
|
| Methods inherited from interface org.mule.umo.lifecycle.Disposable |
dispose |
| Methods inherited from interface org.mule.umo.lifecycle.Initialisable |
initialise |
| Field Detail |
public static final int INT_VALUE_NOT_SET
| Method Detail |
public UMOMessageReceiver registerListener(UMOComponent component,
UMOEndpoint endpoint)
throws Exception
UMOMessageReceiver associated with this endpoint
and registers it with the connector
component - the listening componentendpoint - the endpoint contains the listener endpointUri on which to
listen on.
Exception - if the UMOMessageReceiver cannot be created or the Receiver
cannot be registered
public void unregisterListener(UMOComponent component,
UMOEndpoint endpoint)
throws Exception
component - the listening componentendpoint - the associated endpointDescriptor with the listener
Exception - if the listener cannot be unregistered. If a listener is not
associated with the given endpoint this will not throw an
exceptionpublic boolean isStarted()
public boolean isDisposed()
public boolean isDisposing()
public UMOMessageAdapter getMessageAdapter(Object message)
throws MessagingException
UMOMessageAdapter from the connector for the given
message (data)
message - the data with which to initialise the
UMOMessageAdapter
UMOMessageAdapter for the endpoint
MessagingException - if the message parameter is not supportedUMOMessageAdapter
public UMOStreamMessageAdapter getStreamMessageAdapter(InputStream in,
OutputStream out)
throws MessagingException
UMOStreamMessageAdapter from the connector for the given
message. This Adapter will correctly handle data streaming for this type of
connector
in - the input stream to read the data fromout - the outputStream to write data to. This can be null.
UMOStreamMessageAdapter for the endpoint
MessagingException - if the message parameter is not supportedUMOStreamMessageAdapterpublic String getName()
public void setName(String newName)
newName - the name to associate with the endpointpublic String getProtocol()
public boolean supportsProtocol(String protocol)
public UMOMessageDispatcher getDispatcher(UMOImmutableEndpoint endpoint)
throws UMOException
endpoint - the endpoint that can be used to key cached dispatchers
UMOException - if creation of a component failspublic void setExceptionListener(ExceptionListener listener)
listener - the exception strategy to use with this endpointExceptionListenerpublic ExceptionListener getExceptionListener()
ExceptionListenerpublic void handleException(Exception exception)
exception - the exception that was caughtpublic void setDispatcherFactory(UMOMessageDispatcherFactory factory)
factory - the factory to use when a dispatcher request is madrpublic UMOMessageDispatcherFactory getDispatcherFactory()
public void startConnector()
throws UMOException
UMOException
public void stopConnector()
throws UMOException
UMOExceptionpublic boolean isRemoteSyncEnabled()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||