|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.mule.providers.AbstractConnector
org.mule.tck.testmodels.mule.TestConnector
TestConnector us a mock connector
| Nested Class Summary | |
class |
TestConnector.DummyMessageAdapter
|
| Field Summary |
| Fields inherited from class org.mule.providers.AbstractConnector |
connected, connecting, createDispatcherPerRequest, createMultipleTransactedReceivers, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, receivers, serverSide, sessionHandler, started, startOnConnect |
| Fields inherited from interface org.mule.umo.provider.UMOConnector |
INT_VALUE_NOT_SET |
| Constructor Summary | |
TestConnector()
|
|
| Method Summary | |
UMOMessageReceiver |
createReceiver(UMOComponent component,
UMOEndpoint endpoint)
|
void |
destroyReceiver(UMOMessageReceiver receiver,
UMOEndpoint endpoint)
|
protected void |
doDispose()
Template method to perform any work when destroying the connectoe |
void |
doInitialise()
|
protected void |
doStart()
Template method to perform any work when starting the connectoe |
protected void |
doStop()
Template method to perform any work when stopping the connectoe |
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. |
UMOMessageAdapter |
getMessageAdapter(Object message)
Gets a UMOMessageAdapter from the connector for the given
message (data) |
String |
getProtocol()
|
UMOStreamMessageAdapter |
getStreamMessageAdapter(InputStream in,
OutputStream out)
Gets a UMOStreamMessageAdapter from the connector for the given
message. |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
public TestConnector()
| Method Detail |
public UMOMessageDispatcher getDispatcher(UMOImmutableEndpoint endpoint)
throws UMOException
getDispatcher in interface UMOConnectorgetDispatcher in class AbstractConnectorendpoint - the endpoint that can be used to key cached dispatchers
UMOException - if creation of a component failsprotected void doDispose()
AbstractConnector
doDispose in class AbstractConnector
public void doInitialise()
throws InitialisationException
doInitialise in class AbstractConnectorInitialisationExceptionpublic String getProtocol()
getProtocol in interface UMOConnectorgetProtocol in class AbstractConnector
protected void doStart()
throws UMOException
AbstractConnector
doStart in class AbstractConnectorUMOException - if the method fails
protected void doStop()
throws UMOException
AbstractConnector
doStop in class AbstractConnectorUMOException - if the method fails
public UMOMessageAdapter getMessageAdapter(Object message)
throws MessagingException
UMOConnectorUMOMessageAdapter 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
UMOConnectorUMOStreamMessageAdapter 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 supportedUMOStreamMessageAdapter
public UMOMessageReceiver createReceiver(UMOComponent component,
UMOEndpoint endpoint)
throws Exception
createReceiver in class AbstractConnectorException
public void destroyReceiver(UMOMessageReceiver receiver,
UMOEndpoint endpoint)
throws Exception
destroyReceiver in class AbstractConnectorException
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||