org.mule.providers.rmi
Class RmiConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.mule.providers.AbstractJndiConnector
              extended byorg.mule.providers.rmi.RmiConnector
All Implemented Interfaces:
Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector
Direct Known Subclasses:
EjbConnector, JnpConnector

public class RmiConnector
extends AbstractJndiConnector

RmiConnector can bind or send to a given RMI port on a given host.


Field Summary
static int DEFAULT_RMI_REGISTRY_PORT
           
static int MSG_PARAM_SERVICE_METHOD_NOT_SET
           
static int MSG_PROPERTY_SERVICE_METHOD_PARAM_TYPES_NOT_SET
           
static int NO_RMI_SERVICECLASS_SET
           
protected  long pollingFrequency
           
static String PROPERTY_RMI_SECURITY_POLICY
           
static String PROPERTY_RMI_SERVER_CODEBASE
           
static String PROPERTY_SERVER_CLASS_NAME
           
static String PROPERTY_SERVICE_METHOD_PARAM_TYPES
          The property name that explicitly defines which argument types should be passed to a remote object method invocation.
static String PROPERTY_SERVICE_METHOD_PARAMS_LIST
          The property name for a list of objects used to call a Remote object via an RMI or EJB MessageReceiver
static int RMI_SERVICECLASS_INVOCATION_FAILED
           
 
Fields inherited from class org.mule.providers.AbstractJndiConnector
jndiContext, jndiInitialFactory, jndiProviderProperties, jndiProviderUrl, jndiUrlPkgPrefixes
 
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
RmiConnector()
           
 
Method Summary
 UMOMessageReceiver createReceiver(UMOComponent component, UMOEndpoint endpoint)
           
 void doInitialise()
           
 Method getMethodObject(Remote remoteObject, UMOEvent event)
          Helper method for Dispatchers and Receives to extract the correct method from a Remote object
 long getPollingFrequency()
           
 String getProtocol()
           
 Remote getRemoteObject(UMOImmutableEndpoint endpoint)
           
protected  Object getRemoteRef(UMOImmutableEndpoint endpoint)
           
 SecurityManager getSecurityManager()
           
 String getSecurityPolicy()
           
 String getServerClassName()
          Method getServerClassName
 String getServerCodebase()
          Method getServerCodebase
 void setPollingFrequency(long pollingFrequency)
           
 void setSecurityManager(SecurityManager securityManager)
           
 void setSecurityPolicy(String path)
           
 void setServerClassName(String serverClassName)
          Method setServerClassName
 void setServerCodebase(String serverCodebase)
          Method setServerCodebase
 
Methods inherited from class org.mule.providers.AbstractJndiConnector
getJndiContext, getJndiContext, getJndiInitialFactory, getJndiProviderProperties, getJndiProviderUrl, getJndiUrlPkgPrefixes, initJndiContext, setJndiContext, setJndiInitialFactory, setJndiProviderProperties, setJndiProviderUrl, setJndiUrlPkgPrefixes
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
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, doDispose, doStart, doStop, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiver, getReceiver, getReceiverKey, 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
 

Field Detail

MSG_PARAM_SERVICE_METHOD_NOT_SET

public static final int MSG_PARAM_SERVICE_METHOD_NOT_SET
See Also:
Constant Field Values

MSG_PROPERTY_SERVICE_METHOD_PARAM_TYPES_NOT_SET

public static final int MSG_PROPERTY_SERVICE_METHOD_PARAM_TYPES_NOT_SET
See Also:
Constant Field Values

NO_RMI_SERVICECLASS_SET

public static final int NO_RMI_SERVICECLASS_SET
See Also:
Constant Field Values

RMI_SERVICECLASS_INVOCATION_FAILED

public static final int RMI_SERVICECLASS_INVOCATION_FAILED
See Also:
Constant Field Values

DEFAULT_RMI_REGISTRY_PORT

public static final int DEFAULT_RMI_REGISTRY_PORT
See Also:
Constant Field Values

PROPERTY_RMI_SECURITY_POLICY

public static final String PROPERTY_RMI_SECURITY_POLICY
See Also:
Constant Field Values

PROPERTY_RMI_SERVER_CODEBASE

public static final String PROPERTY_RMI_SERVER_CODEBASE
See Also:
Constant Field Values

PROPERTY_SERVER_CLASS_NAME

public static final String PROPERTY_SERVER_CLASS_NAME
See Also:
Constant Field Values

PROPERTY_SERVICE_METHOD_PARAM_TYPES

public static final String PROPERTY_SERVICE_METHOD_PARAM_TYPES
The property name that explicitly defines which argument types should be passed to a remote object method invocation. This is a comma-separate list for fully qualified classnames. If this property is not set on an outbound endpoint, the argument types will be determined automatically from the payload of the current message

See Also:
Constant Field Values

PROPERTY_SERVICE_METHOD_PARAMS_LIST

public static final String PROPERTY_SERVICE_METHOD_PARAMS_LIST
The property name for a list of objects used to call a Remote object via an RMI or EJB MessageReceiver

See Also:
Constant Field Values

pollingFrequency

protected long pollingFrequency
Constructor Detail

RmiConnector

public RmiConnector()
Method Detail

getProtocol

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

getSecurityPolicy

public String getSecurityPolicy()
Returns:
Returns the securityPolicy.

setSecurityPolicy

public void setSecurityPolicy(String path)
Parameters:
path - The securityPolicy to set.

getServerCodebase

public String getServerCodebase()
Method getServerCodebase

Returns:

setServerCodebase

public void setServerCodebase(String serverCodebase)
Method setServerCodebase

Parameters:
serverCodebase -

getServerClassName

public String getServerClassName()
Method getServerClassName

Returns:

setServerClassName

public void setServerClassName(String serverClassName)
Method setServerClassName

Parameters:
serverClassName -

doInitialise

public void doInitialise()
                  throws InitialisationException
Overrides:
doInitialise in class AbstractServiceEnabledConnector
Throws:
InitialisationException

getSecurityManager

public SecurityManager getSecurityManager()

setSecurityManager

public void setSecurityManager(SecurityManager securityManager)

createReceiver

public UMOMessageReceiver createReceiver(UMOComponent component,
                                         UMOEndpoint endpoint)
                                  throws Exception
Overrides:
createReceiver in class AbstractServiceEnabledConnector
Throws:
Exception

getMethodObject

public Method getMethodObject(Remote remoteObject,
                              UMOEvent event)
                       throws UMOException,
                              NoSuchMethodException,
                              ClassNotFoundException
Helper method for Dispatchers and Receives to extract the correct method from a Remote object

Parameters:
remoteObject - The remote object on which to invoke the method
event - The current event being processed
Returns:
Throws:
UMOException
NoSuchMethodException
ClassNotFoundException

getRemoteRef

protected Object getRemoteRef(UMOImmutableEndpoint endpoint)
                       throws IOException,
                              NotBoundException,
                              NamingException,
                              InitialisationException
Throws:
IOException
NotBoundException
NamingException
InitialisationException

getRemoteObject

public Remote getRemoteObject(UMOImmutableEndpoint endpoint)
                       throws IOException,
                              NotBoundException,
                              NamingException,
                              InitialisationException
Throws:
IOException
NotBoundException
NamingException
InitialisationException

getPollingFrequency

public long getPollingFrequency()

setPollingFrequency

public void setPollingFrequency(long pollingFrequency)


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