org.mule.providers.gs
Class GSConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.mule.providers.space.SpaceConnector
              extended byorg.mule.providers.gs.GSConnector
All Implemented Interfaces:
Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector

public class GSConnector
extends SpaceConnector

Provides a Space connector to be used with the GigaSpaces JavaSpaces implementation.


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
GSConnector()
           
 
Method Summary
 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(UMOEndpoint endpoint)
          Will look up a space based on the URI.
protected  String getSpaceKey(UMOImmutableEndpoint endpoint)
           
 long getTransactionTimeout()
           
 void setTransactionTimeout(long transactionTimeout)
           
 
Methods inherited from class org.mule.providers.space.SpaceConnector
doDispose, doInitialise, getSpace, getSpaceFactory, getSpaceProperties, setSpaceFactory, setSpaceProperties
 
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

GSConnector

public GSConnector()
Method Detail

getProtocol

public String getProtocol()
Specified by:
getProtocol in interface UMOConnector
Overrides:
getProtocol in class SpaceConnector

getTransactionTimeout

public long getTransactionTimeout()

setTransactionTimeout

public void setTransactionTimeout(long transactionTimeout)

getReceiverKey

protected Object getReceiverKey(UMOComponent component,
                                UMOEndpoint endpoint)
The method determines the key used to store the receiver against.

Overrides:
getReceiverKey in class SpaceConnector
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

getSpace

public UMOSpace getSpace(UMOEndpoint 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

getSpace

public UMOSpace getSpace(String spaceUrl)
                  throws UMOSpaceException
Overrides:
getSpace in class SpaceConnector
Throws:
UMOSpaceException

getSpaceKey

protected String getSpaceKey(UMOImmutableEndpoint endpoint)
Overrides:
getSpaceKey in class SpaceConnector


Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.