org.mule.tck.testmodels.mule
Class TestConnector

java.lang.Object
  extended by org.mule.transport.AbstractConnector
      extended by 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


Field Summary
static String TEST
           
 
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
 
Fields inherited from interface org.mule.api.transport.Connector
INT_VALUE_NOT_SET
 
Fields inherited from interface org.mule.api.lifecycle.Disposable
PHASE_NAME
 
Constructor Summary
TestConnector(MuleContext context)
           
 
Method Summary
 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)
           
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

TEST

public static final String TEST
See Also:
Constant Field Values
Constructor Detail

TestConnector

public TestConnector(MuleContext context)
Method Detail

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.