org.springframework.integration.adapter.rmi
Class RmiSourceAdapter

java.lang.Object
  org.springframework.integration.adapter.MessageHandlingSourceAdapter
      org.springframework.integration.adapter.rmi.RmiSourceAdapter

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, MessageHandler

public class RmiSourceAdapter
extends MessageHandlingSourceAdapter

A source channel adapter for RMI-based remoting.

Author:

Mark Fisher

Field Summary

private java.lang.String	registryHost
private int	registryPort
private org.springframework.remoting.support.RemoteInvocationExecutor	remoteInvocationExecutor
static java.lang.String	SERVICE_NAME_PREFIX

Fields inherited from class org.springframework.integration.adapter.MessageHandlingSourceAdapter

lifecycleMonitor

Constructor Summary

RmiSourceAdapter(MessageChannel channel)

Method Summary

void	initialize() Subclasses may override this method for initialization.
void	setRegistryHost(java.lang.String registryHost)
void	setRegistryPort(int registryPort)
void	setRemoteInvocationExecutor(org.springframework.remoting.support.RemoteInvocationExecutor remoteInvocationExecutor)

Methods inherited from class org.springframework.integration.adapter.MessageHandlingSourceAdapter

afterPropertiesSet, getChannel, handle, setExpectReply, setReplyTimeout, setRequestTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SERVICE_NAME_PREFIX

public static final java.lang.String SERVICE_NAME_PREFIX

See Also:

Constant Field Values

registryHost

private volatile java.lang.String registryHost

registryPort

private volatile int registryPort

remoteInvocationExecutor

private volatile org.springframework.remoting.support.RemoteInvocationExecutor remoteInvocationExecutor

Constructor Detail

RmiSourceAdapter

public RmiSourceAdapter(MessageChannel channel)

Method Detail

setRegistryHost

public void setRegistryHost(java.lang.String registryHost)

setRegistryPort

public void setRegistryPort(int registryPort)

setRemoteInvocationExecutor

public void setRemoteInvocationExecutor(org.springframework.remoting.support.RemoteInvocationExecutor remoteInvocationExecutor)

initialize

public void initialize()
                throws java.rmi.RemoteException

Description copied from class: MessageHandlingSourceAdapter

Subclasses may override this method for initialization.

Overrides:

initialize in class MessageHandlingSourceAdapter

Throws:

java.rmi.RemoteException