public class RmiInboundGateway extends MessagingGatewaySupport implements RequestReplyExchanger, org.springframework.beans.factory.InitializingBean
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SERVICE_NAME_PREFIX |
logger
Constructor and Description |
---|
RmiInboundGateway() |
Modifier and Type | Method and Description |
---|---|
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.
|
doStart, doStop, receive, send, sendAndReceive, sendAndReceiveMessage, setErrorChannel, setReplyChannel, setReplyMapper, setReplyTimeout, setRequestMapper, setRequestTimeout, setShouldTrack
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
afterPropertiesSet
getComponentName
public static final java.lang.String SERVICE_NAME_PREFIX
public void setRequestChannel(MessageChannel requestChannel)
null
, and it must have a name.setRequestChannel
in class MessagingGatewaySupport
requestChannel
- the channel to which request messages will be sentpublic void setExpectReply(boolean expectReply)
true
'.public void setRegistryHost(java.lang.String registryHost)
public void setRegistryPort(int registryPort)
public void setRemoteInvocationExecutor(org.springframework.remoting.support.RemoteInvocationExecutor remoteInvocationExecutor)
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class MessagingGatewaySupport
protected void onInit() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class MessagingGatewaySupport
java.lang.Exception
public Message<?> exchange(Message<?> message)
exchange
in interface RequestReplyExchanger