org.springframework.integration.rmi
Class RmiInboundGateway

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.endpoint.AbstractEndpoint
          org.springframework.integration.gateway.MessagingGatewaySupport
              org.springframework.integration.rmi.RmiInboundGateway

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, NamedComponent, RequestReplyExchanger, TrackableComponent

public class RmiInboundGateway
extends MessagingGatewaySupport
implements RequestReplyExchanger, org.springframework.beans.factory.InitializingBean

An inbound Messaging Gateway for RMI-based remoting.

Author:

Mark Fisher

Field Summary

static java.lang.String

SERVICE_NAME_PREFIX

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

RmiInboundGateway()

Method Summary

Message<?>	exchange(Message<?> message)
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
protected void	onInit() Subclasses may implement this for initialization logic.
void	setExpectReply(boolean expectReply) Specify whether the gateway should be expected to return a reply.
void	setRegistryHost(java.lang.String registryHost)
void	setRegistryPort(int registryPort)
void	setRemoteInvocationExecutor(org.springframework.remoting.support.RemoteInvocationExecutor remoteInvocationExecutor)
void	setRequestChannel(MessageChannel requestChannel) Specify the request channel where messages will be sent.

Methods inherited from class org.springframework.integration.gateway.MessagingGatewaySupport

doStart, doStop, receive, send, sendAndReceive, sendAndReceiveMessage, setErrorChannel, setReplyChannel, setReplyMapper, setReplyTimeout, setRequestMapper, setRequestTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.InitializingBean

afterPropertiesSet

Methods inherited from interface org.springframework.integration.context.NamedComponent

getComponentName

Field Detail

SERVICE_NAME_PREFIX

public static final java.lang.String SERVICE_NAME_PREFIX

See Also:

Constant Field Values

Constructor Detail

RmiInboundGateway

public RmiInboundGateway()

Method Detail

setRequestChannel

public void setRequestChannel(MessageChannel requestChannel)

Specify the request channel where messages will be sent. It must not be null, and it must have a name.

Overrides:

setRequestChannel in class MessagingGatewaySupport

Parameters:

requestChannel - the channel to which request messages will be sent

setExpectReply

public void setExpectReply(boolean expectReply)

Specify whether the gateway should be expected to return a reply. The default is 'true'.

setRegistryHost

public void setRegistryHost(java.lang.String registryHost)

setRegistryPort

public void setRegistryPort(int registryPort)

setRemoteInvocationExecutor

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

getComponentType

public java.lang.String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class MessagingGatewaySupport

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class MessagingGatewaySupport

Throws:

java.lang.Exception

exchange

public Message<?> exchange(Message<?> message)

Specified by:

exchange in interface RequestReplyExchanger