public class RmiConnector extends AbstractJndiConnector
RmiConnector
can bind or send to a given RMI port on a given host.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_RMI_muleRegistry_PORT |
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 String |
RMI |
jndiContext, jndiInitialFactory, jndiProviderProperties, jndiProviderUrl, jndiUrlPkgPrefixes
createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
INT_VALUE_NOT_SET
PHASE_NAME
Constructor and Description |
---|
RmiConnector(MuleContext context) |
Modifier and Type | Method and Description |
---|---|
MessageReceiver |
createReceiver(FlowConstruct flowConstruct,
InboundEndpoint endpoint)
Create a Message receiver for this connector
|
protected void |
doConnect()
Template method where any connections should be made for the connector
|
protected void |
doDisconnect()
Template method where any connected resources used by the connector should be
disconnected
|
protected void |
doDispose()
Template method to perform any work when destroying the connectoe
|
protected void |
doInitialise() |
protected void |
doStart()
Template method to perform any work when starting the connectoe
|
protected void |
doStop()
Template method to perform any work when stopping the connectoe
|
protected Class[] |
getArgTypes(Object args,
MuleEvent fromEvent) |
Method |
getMethodObject(Remote remoteObject,
MuleEvent event,
OutboundEndpoint outboundEndpoint)
Helper method for Dispatchers and Receives to extract the correct method from
a Remote object
|
long |
getPollingFrequency() |
String |
getProtocol() |
Remote |
getRemoteObject(ImmutableEndpoint endpoint) |
protected Object |
getRemoteRef(ImmutableEndpoint endpoint) |
SecurityManager |
getSecurityManager() |
String |
getSecurityPolicy() |
String |
getServerClassName() |
String |
getServerCodebase() |
void |
setPollingFrequency(long pollingFrequency) |
void |
setSecurityManager(SecurityManager securityManager) |
void |
setSecurityPolicy(String path) |
void |
setServerClassName(String serverClassName) |
void |
setServerCodebase(String serverCodebase) |
protected Class[] |
stringsToClasses(Collection strings) |
getJndiContext, getJndiContext, getJndiInitialFactory, getJndiProviderProperties, getJndiProviderUrl, getJndiUrlPkgPrefixes, initJndiContext, setJndiContext, setJndiInitialFactory, setJndiProviderProperties, setJndiProviderUrl, setJndiUrlPkgPrefixes
borrowDispatcher, clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createOperationResource, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, getCanonicalURI, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOperationResourceFactory, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getReplyToHandler, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, returnDispatcher, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted
public static final String RMI
public static final int DEFAULT_RMI_muleRegistry_PORT
public static final String PROPERTY_RMI_SECURITY_POLICY
public static final String PROPERTY_RMI_SERVER_CODEBASE
public static final String PROPERTY_SERVER_CLASS_NAME
public static final String PROPERTY_SERVICE_METHOD_PARAM_TYPES
public static final String PROPERTY_SERVICE_METHOD_PARAMS_LIST
protected long pollingFrequency
public RmiConnector(MuleContext context)
protected void doInitialise() throws InitialisationException
doInitialise
in class AbstractConnector
InitialisationException
protected void doDispose()
AbstractConnector
doDispose
in class AbstractConnector
protected void doConnect() throws Exception
AbstractConnector
doConnect
in class AbstractConnector
Exception
protected void doDisconnect() throws Exception
AbstractConnector
doDisconnect
in class AbstractConnector
Exception
protected void doStart() throws MuleException
AbstractConnector
doStart
in class AbstractConnector
MuleException
- if the method failsprotected void doStop() throws MuleException
AbstractConnector
doStop
in class AbstractConnector
MuleException
- if the method failspublic String getProtocol()
public String getSecurityPolicy()
public void setSecurityPolicy(String path)
public String getServerCodebase()
public void setServerCodebase(String serverCodebase)
public String getServerClassName()
public void setServerClassName(String serverClassName)
public SecurityManager getSecurityManager()
public void setSecurityManager(SecurityManager securityManager)
public MessageReceiver createReceiver(FlowConstruct flowConstruct, InboundEndpoint endpoint) throws Exception
AbstractConnector
createReceiver
in class AbstractConnector
flowConstruct
- the service that will receive events from this receiver, the
listenerendpoint
- the endpoint that defies this inbound communicationTransportServiceDescriptor
initialised using the service and endpoint.Exception
- if there is a problem creating the receiver. This exception
really depends on the underlying transport, thus any exception
could be thrownpublic Method getMethodObject(Remote remoteObject, MuleEvent event, OutboundEndpoint outboundEndpoint) throws MuleException, NoSuchMethodException, ClassNotFoundException
remoteObject
- The remote object on which to invoke the methodevent
- The current event being processedMuleException
NoSuchMethodException
ClassNotFoundException
protected Class[] stringsToClasses(Collection strings) throws ClassNotFoundException
ClassNotFoundException
protected Object getRemoteRef(ImmutableEndpoint endpoint) throws IOException, NotBoundException, NamingException, InitialisationException
public Remote getRemoteObject(ImmutableEndpoint endpoint) throws IOException, NotBoundException, NamingException, InitialisationException
public long getPollingFrequency()
public void setPollingFrequency(long pollingFrequency)
protected Class[] getArgTypes(Object args, MuleEvent fromEvent) throws ClassNotFoundException, TransformerException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.