org.springframework.integration.rmi
Class RmiInboundGateway

java.lang.Object
  extended by org.springframework.integration.context.IntegrationObjectSupport
      extended by org.springframework.integration.endpoint.AbstractEndpoint
          extended by org.springframework.integration.gateway.MessagingGatewaySupport
              extended by 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, org.springframework.integration.context.NamedComponent, org.springframework.integration.gateway.RequestReplyExchanger, org.springframework.integration.history.TrackableComponent

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

An inbound Messaging Gateway for RMI-based remoting.


Field Summary
static java.lang.String SERVICE_NAME_PREFIX
           
 
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
logger
 
Constructor Summary
RmiInboundGateway()
           
 
Method Summary
 org.springframework.integration.Message<?> exchange(org.springframework.integration.Message<?> message)
           
 java.lang.String getComponentType()
           
protected  void onInit()
           
 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(org.springframework.integration.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(org.springframework.integration.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 org.springframework.integration.gateway.MessagingGatewaySupport

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()
Specified by:
getComponentType in interface org.springframework.integration.context.NamedComponent
Overrides:
getComponentType in class org.springframework.integration.gateway.MessagingGatewaySupport

onInit

protected void onInit()
               throws java.lang.Exception
Overrides:
onInit in class org.springframework.integration.gateway.MessagingGatewaySupport
Throws:
java.lang.Exception

exchange

public org.springframework.integration.Message<?> exchange(org.springframework.integration.Message<?> message)
Specified by:
exchange in interface org.springframework.integration.gateway.RequestReplyExchanger