public class RmiInboundGateway extends MessagingGatewaySupport implements RequestReplyExchanger, InitializingBean
| Modifier and Type | Field and Description |
|---|---|
static String |
SERVICE_NAME_PREFIX |
lifecycleCondition, lifecycleLocklogger| Constructor and Description |
|---|
RmiInboundGateway() |
| Modifier and Type | Method and Description |
|---|---|
Message<?> |
exchange(Message<?> message) |
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(String registryHost) |
void |
setRegistryPort(int registryPort) |
void |
setRemoteInvocationExecutor(RemoteInvocationExecutor remoteInvocationExecutor) |
void |
setRequestChannel(MessageChannel requestChannel)
Specify the request channel where messages will be sent.
|
doStart, doStop, getErrorChannel, getReplyChannel, getRequestChannel, receive, send, sendAndReceive, sendAndReceiveMessage, setErrorChannel, setErrorChannelName, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrackdoStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitafterPropertiesSetgetComponentNamepublic static final String SERVICE_NAME_PREFIX
public void setRequestChannel(MessageChannel requestChannel)
null, and it must have a name.setRequestChannel in class MessagingGatewaySupportrequestChannel - the channel to which request messages will be sentpublic void setExpectReply(boolean expectReply)
true'.expectReply - true when a reply is expected.public void setRegistryHost(String registryHost)
public void setRegistryPort(int registryPort)
public void setRemoteInvocationExecutor(RemoteInvocationExecutor remoteInvocationExecutor)
public String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class MessagingGatewaySupportprotected void onInit()
throws Exception
IntegrationObjectSupportonInit in class MessagingGatewaySupportException - Any exception.public Message<?> exchange(Message<?> message)
exchange in interface RequestReplyExchanger