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.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ExpressionCapable, RequestReplyExchanger, NamedComponent, IntegrationManagement, MessageSourceMetrics, TrackableComponent

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

An inbound Messaging Gateway for RMI-based remoting.

Author:

Mark Fisher, Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SERVICE_NAME_PREFIX

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

messagingTemplate

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

lifecycleCondition, lifecycleLock

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

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
RmiInboundGateway()

Method Summary

Modifier and Type	Method and Description
void	destroy()
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.
void	setRequestChannelName(java.lang.String requestChannelName) Set the request channel name.

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

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, setRequestMapper, setRequestTimeout, setShouldTrack

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

doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stop

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

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, 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.support.context.NamedComponent

getComponentName

Methods inherited from interface org.springframework.integration.support.management.MessageSourceMetrics

setCounter

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

registerMetricsCaptor

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.messaging.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

setRequestChannelName

public void setRequestChannelName(java.lang.String requestChannelName)

Description copied from class: MessagingGatewaySupport

Set the request channel name.

Overrides:

setRequestChannelName in class MessagingGatewaySupport

Parameters:

requestChannelName - the channel bean name 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'.

Parameters:

expectReply - true when a reply is expected.

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 - Any exception.

exchange

public org.springframework.messaging.Message<?> exchange(org.springframework.messaging.Message<?> message)

Specified by:

exchange in interface RequestReplyExchanger

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Overrides:

destroy in class AbstractEndpoint

Throws:

java.lang.Exception