org.mule.providers.space
Class SpaceConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.mule.providers.space.SpaceConnector
- All Implemented Interfaces:
- Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector
- Direct Known Subclasses:
- GSConnector
- public class SpaceConnector
- extends AbstractServiceEnabledConnector
Provides generic connectivity to 'Spaces' that implement the Mule Space API, i.e.
Gigaspaces, JCache implementations, Rio can be accessed as well as a mule file,
Journal or VM space.
| 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 |
| Methods inherited from class org.mule.providers.AbstractConnector |
checkDisposed, connect, createDispatcher, destroyReceiver, disconnect, dispose, disposeDispatchers, disposeReceivers, doConnect, doDisconnect, doStart, doStop, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiver, getReceiver, getReceivers, getReceivers, getReceiverThreadingProfile, getReplyToHandler, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initialise, isConnected, isCreateDispatcherPerRequest, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isServerSide, isStarted, isUseSingleDispatcherThreadPool, isUseSingleReceiverThreadPool, lookupDispatcher, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithotPrefix, setConnectionStrategy, setCreateDispatcherPerRequest, setCreateMultipleTransactedReceivers, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setEnableMessageEvents, setExceptionListener, setName, setReceiverThreadingProfile, setServerSide, setSessionHandler, setSupportedProtocols, setUseSingleDispatcherThreadPool, setUseSingleReceiverThreadPool, startConnector, stopConnector, supportsProtocol, unregisterListener, unregisterSupportedProtocol, workAccepted, workCompleted, workRejected, workStarted |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SpaceConnector
public SpaceConnector()
getProtocol
public String getProtocol()
- Specified by:
getProtocol in interface UMOConnector- Specified by:
getProtocol in class AbstractConnector
doInitialise
public void doInitialise()
throws InitialisationException
- Overrides:
doInitialise in class AbstractServiceEnabledConnector
- Throws:
InitialisationException
getSpace
public UMOSpace getSpace(String spaceUrl)
throws UMOSpaceException
- Throws:
UMOSpaceException
getSpace
public UMOSpace getSpace(UMOImmutableEndpoint endpoint)
throws UMOSpaceException
- Will look up a space based on the URI. If the Space is created this method
will honour the transaction information on the endpoint and set the space up
accordingly
- Parameters:
endpoint -
- Returns:
-
- Throws:
UMOSpaceException
getSpaceKey
protected String getSpaceKey(UMOImmutableEndpoint endpoint)
getSpaceFactory
public UMOSpaceFactory getSpaceFactory()
setSpaceFactory
public void setSpaceFactory(UMOSpaceFactory spaceFactory)
getSpaceProperties
public Map getSpaceProperties()
setSpaceProperties
public void setSpaceProperties(Map spaceProperties)
doDispose
protected void doDispose()
- Template method to perform any work when destroying the connectoe
- Overrides:
doDispose in class AbstractConnector
getReceiverKey
protected Object getReceiverKey(UMOComponent component,
UMOEndpoint endpoint)
- The method determines the key used to store the receiver against.
- Overrides:
getReceiverKey in class AbstractConnector
- Parameters:
component - the component for which the endpoint is being registeredendpoint - the endpoint being registered for the component
- Returns:
- the key to store the newly created receiver against
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.