org.mule.tck.testmodels.mule
Class TestConnector
java.lang.Object
org.mule.transport.AbstractConnector
org.mule.tck.testmodels.mule.TestConnector
- All Implemented Interfaces:
- EventListener, javax.resource.spi.work.WorkListener, Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, NameableObject, NamedObject, Connectable, Connector
- Direct Known Subclasses:
- TestConnector2
public class TestConnector
- extends AbstractConnector
TestConnector
use a mock connector
Fields inherited from class org.mule.transport.AbstractConnector |
createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect |
Methods inherited from class org.mule.transport.AbstractConnector |
clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOperationResourceFactory, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted |
TEST
public static final String TEST
- See Also:
- Constant Field Values
TestConnector
public TestConnector(MuleContext context)
getProtocol
public String getProtocol()
doInitialise
protected void doInitialise()
- Specified by:
doInitialise
in class AbstractConnector
doConnect
protected void doConnect()
- Specified by:
doConnect
in class AbstractConnector
doStart
protected void doStart()
- Specified by:
doStart
in class AbstractConnector
doStop
protected void doStop()
- Specified by:
doStop
in class AbstractConnector
doDisconnect
protected void doDisconnect()
- Specified by:
doDisconnect
in class AbstractConnector
doDispose
protected void doDispose()
- Specified by:
doDispose
in class AbstractConnector
getSomeProperty
public String getSomeProperty()
setSomeProperty
public void setSomeProperty(String someProperty)
getReceiverKey
protected Object getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
- Overrides:
getReceiverKey
in class AbstractConnector
createReceiver
public MessageReceiver createReceiver(FlowConstruct flowConstuct,
InboundEndpoint endpoint)
throws Exception
- Overrides:
createReceiver
in class AbstractConnector
- Throws:
Exception
getServiceDescriptor
public TransportServiceDescriptor getServiceDescriptor()
- Open up the access to the service descriptor for testing purposes.
- Overrides:
getServiceDescriptor
in class AbstractConnector
destroyReceiver
public void destroyReceiver(MessageReceiver receiver,
InboundEndpoint endpoint)
throws Exception
- Throws:
Exception
getDispatchers
public ConfigurableKeyedObjectPool getDispatchers()
getInitialiseCount
public int getInitialiseCount()
getConnectCount
public int getConnectCount()
getStartCount
public int getStartCount()
getStopCount
public int getStopCount()
getDisconnectCount
public int getDisconnectCount()
getDisposeCount
public int getDisposeCount()
getOutboundEndpointMessageProcessor
public MessageProcessor getOutboundEndpointMessageProcessor(OutboundEndpoint endpoint)
throws MuleException
- Throws:
MuleException
setFailAtStartup
public void setFailAtStartup(boolean failAtStartup)
isFailAtStartup
public boolean isFailAtStartup()
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.