org.mule.providers.vm
Class VMConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.mule.providers.vm.VMConnector
- All Implemented Interfaces:
- Disposable, java.beans.ExceptionListener, Initialisable, Startable, Stoppable, UMOConnector
- public class VMConnector
- extends AbstractServiceEnabledConnector
VMConnector
A simple endpoint wrapper to allow a Mule component to
be accessed from an endpoint
- Version:
- $Revision: 1.1.1.1 $
- Author:
- Ross Mason
Fields inherited from class org.mule.providers.AbstractConnector |
DEFAULT_RETRY_COUNT, DEFAULT_RETRY_FREQUENCY, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, exceptionStrategy, initialised, logger, name, receivers, started |
Methods inherited from class org.mule.providers.AbstractConnector |
createDispatcher, destroyReceiver, dispose, exceptionThrown, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcherFactory, getDispatcherThreadingProfile, getExceptionStrategy, getName, getReceiverKey, getReceiverThreadingProfile, getReplyToHandler, getRetryCount, getRetryFrequency, handleException, initialise, isDisposed, isDisposeDispatcherOnCompletion, isStarted, registerListener, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setDisposeDispatcherOnCompletion, setExceptionStrategy, setName, setReceiverThreadingProfile, setRetryCount, setRetryFrequency, start, startConnector, stop, stopConnector, unregisterListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
VMConnector
public VMConnector()
doInitialise
public void doInitialise()
throws InitialisationException
- Overrides:
doInitialise
in class AbstractServiceEnabledConnector
- Throws:
InitialisationException
createReceiver
public UMOMessageReceiver createReceiver(UMOComponent component,
UMOEndpoint endpoint)
throws java.lang.Exception
- Overrides:
createReceiver
in class AbstractServiceEnabledConnector
- Throws:
java.lang.Exception
getMessageAdapter
public UMOMessageAdapter getMessageAdapter(java.lang.Object message)
throws MessageException
- Description copied from class:
AbstractServiceEnabledConnector
- Gets a
UMOMessageAdapter
for the endpoint for the given message (data)
- Specified by:
getMessageAdapter
in interface UMOConnector
- Overrides:
getMessageAdapter
in class AbstractServiceEnabledConnector
- Parameters:
message
- the data with which to initialise the UMOMessageAdapter
- Returns:
- the
UMOMessageAdapter
for the endpoint
- Throws:
MessageException
- if the message parameter is not supported- See Also:
UMOMessageAdapter
getProtocol
public java.lang.String getProtocol()
- Specified by:
getProtocol
in interface UMOConnector
- Specified by:
getProtocol
in class AbstractConnector
disposeConnector
protected void disposeConnector()
throws UMOException
- Description copied from class:
AbstractConnector
- Template method to perform any work when destroying the connectoe
- Overrides:
disposeConnector
in class AbstractConnector
- Throws:
UMOException
- if the method fails
isQueueEvents
public boolean isQueueEvents()
setQueueEvents
public void setQueueEvents(boolean queueEvents)
getQueueProfile
public QueueProfile getQueueProfile()
setQueueProfile
public void setQueueProfile(QueueProfile queueProfile)
setMaxQueues
public void setMaxQueues(int maxQueues)
getRecieverByEndpoint
protected UMOMessageReceiver getRecieverByEndpoint(UMOEndpointURI endpointUri)
throws EndpointException
- Throws:
EndpointException
Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.