public class RmiInboundGateway extends MessagingGatewaySupport implements RequestReplyExchanger, org.springframework.beans.factory.InitializingBean
IntegrationManagement.ManagementOverrides
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SERVICE_NAME_PREFIX |
messagingTemplate
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
RmiInboundGateway() |
Modifier and Type | Method and Description |
---|---|
org.springframework.messaging.Message<?> |
exchange(org.springframework.messaging.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(org.springframework.messaging.MessageChannel requestChannel)
Specify the request channel where messages will be sent.
|
buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, getReplyChannel, getRequestChannel, isCountsEnabled, isLoggingEnabled, receive, receive, receiveMessage, receiveMessage, registerReplyMessageCorrelatorIfNecessary, reset, send, sendAndReceive, sendAndReceiveMessage, sendAndReceiveMessageReactive, setCountsEnabled, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setLoggingEnabled, setManagedName, setManagedType, setReplyChannel, setReplyChannelName, setReplyMapper, setReplyTimeout, setRequestChannelName, setRequestMapper, setRequestTimeout, setShouldTrack
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
afterPropertiesSet
getComponentName
setCounter
registerMetricsCaptor
public static final java.lang.String SERVICE_NAME_PREFIX
public void setRequestChannel(org.springframework.messaging.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
'.expectReply
- true when a reply is expected.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
- Any exception.public org.springframework.messaging.Message<?> exchange(org.springframework.messaging.Message<?> message)
exchange
in interface RequestReplyExchanger