org.mule.providers.space
Class SpaceConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.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.


Field Summary
 
Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector
serviceDescriptor, serviceOverrides
 
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
 
Fields inherited from interface org.mule.umo.provider.UMOConnector
INT_VALUE_NOT_SET
 
Constructor Summary
SpaceConnector()
           
 
Method Summary
protected  void doDispose()
          Template method to perform any work when destroying the connectoe
 void doInitialise()
           
 String getProtocol()
           
protected  Object getReceiverKey(UMOComponent component, UMOEndpoint endpoint)
          The method determines the key used to store the receiver against.
 UMOSpace getSpace(String spaceUrl)
           
 UMOSpace getSpace(UMOImmutableEndpoint endpoint)
          Will look up a space based on the URI.
 UMOSpaceFactory getSpaceFactory()
           
protected  String getSpaceKey(UMOImmutableEndpoint endpoint)
           
 Map getSpaceProperties()
           
 void setSpaceFactory(UMOSpaceFactory spaceFactory)
           
 void setSpaceProperties(Map spaceProperties)
           
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
createReceiver, getMessageAdapter, getServiceDescriptor, getServiceOverrides, getStreamMessageAdapter, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides
 
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
 

Constructor Detail

SpaceConnector

public SpaceConnector()
Method Detail

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 registered
endpoint - 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.