public class TestConnector extends AbstractConnector
TestConnector
use a mock connectorModifier and Type | Field and Description |
---|---|
static String |
TEST |
connecting, createMultipleTransactedReceivers, DEFAULT_CONTEXT_START_TIMEOUT, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, MULE_CONTEXT_START_TIMEOUT_SYSTEM_PROPERTY, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
PROPERTY_NAME
Constructor and Description |
---|
TestConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
createReceiver(FlowConstruct flowConstuct,
InboundEndpoint endpoint) |
void |
destroyReceiver(MessageReceiver receiver,
InboundEndpoint endpoint) |
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected void |
doInitialise() |
protected void |
doStart() |
protected void |
doStop() |
int |
getConnectCount() |
int |
getDisconnectCount() |
ConfigurableKeyedObjectPool |
getDispatchers() |
int |
getDisposeCount() |
int |
getInitialiseCount() |
MessageProcessor |
getOutboundEndpointMessageProcessor(OutboundEndpoint endpoint) |
String |
getProtocol() |
protected Object |
getReceiverKey(FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TransportServiceDescriptor |
getServiceDescriptor()
Open up the access to the service descriptor for testing purposes.
|
String |
getSomeProperty() |
int |
getStartCount() |
int |
getStopCount() |
boolean |
isFailAtStartup() |
void |
setFailAtStartup(boolean failAtStartup) |
void |
setSomeProperty(String someProperty) |
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connect, connectConnectorAndReceivers, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, fireNotification, getCanonicalURI, 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, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, returnDispatcher, 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
getAnnotation, getAnnotations, setAnnotations
public static final String TEST
public TestConnector(MuleContext context)
public String getProtocol()
protected void doInitialise()
doInitialise
in class AbstractConnector
protected void doConnect()
doConnect
in class AbstractConnector
protected void doStart()
doStart
in class AbstractConnector
protected void doStop()
doStop
in class AbstractConnector
protected void doDisconnect()
doDisconnect
in class AbstractConnector
protected void doDispose()
doDispose
in class AbstractConnector
public String getSomeProperty()
public void setSomeProperty(String someProperty)
protected Object getReceiverKey(FlowConstruct flowConstruct, InboundEndpoint endpoint)
getReceiverKey
in class AbstractConnector
public MessageReceiver createReceiver(FlowConstruct flowConstuct, InboundEndpoint endpoint) throws Exception
createReceiver
in class AbstractConnector
Exception
public TransportServiceDescriptor getServiceDescriptor()
getServiceDescriptor
in class AbstractConnector
public void destroyReceiver(MessageReceiver receiver, InboundEndpoint endpoint) throws Exception
Exception
public ConfigurableKeyedObjectPool getDispatchers()
public int getInitialiseCount()
public int getConnectCount()
public int getStartCount()
public int getStopCount()
public int getDisconnectCount()
public int getDisposeCount()
public MessageProcessor getOutboundEndpointMessageProcessor(OutboundEndpoint endpoint) throws MuleException
MuleException
public void setFailAtStartup(boolean failAtStartup)
public boolean isFailAtStartup()
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.