org.springframework.integration.endpoint
Class DefaultMessageEndpoint

java.lang.Object
  org.springframework.integration.endpoint.DefaultMessageEndpoint

All Implemented Interfaces:

org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, ChannelRegistryAware, MessageEndpoint, MessageHandler

public class DefaultMessageEndpoint
extends java.lang.Object
implements MessageEndpoint, ChannelRegistryAware, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.BeanNameAware

Default implementation of the MessageEndpoint interface.

Author:

Mark Fisher

Constructor Summary

DefaultMessageEndpoint()

DefaultMessageEndpoint(MessageHandler handler)

Method Summary

void	addMessageSelector(MessageSelector messageSelector)
void	afterPropertiesSet()
ConcurrencyPolicy	getConcurrencyPolicy()
java.lang.String	getDefaultOutputChannelName()
MessageHandler	getHandler()
java.lang.String	getName()
Subscription	getSubscription()
Message<?>	handle(Message<?> message)
boolean	hasErrorHandler()
boolean	isRunning()
void	setBeanName(java.lang.String beanName)
void	setChannelRegistry(ChannelRegistry channelRegistry) Set the channel registry to use for looking up channels by name.
void	setConcurrencyPolicy(ConcurrencyPolicy concurrencyPolicy)
void	setDefaultOutputChannelName(java.lang.String defaultOutputChannelName) Set the name of the channel to which this endpoint can send reply messages by default.
void	setErrorHandler(ErrorHandler errorHandler)
void	setHandler(MessageHandler handler) Set the handler to be invoked for each consumed message.
void	setName(java.lang.String name)
void	setSubscription(Subscription subscription)
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultMessageEndpoint

public DefaultMessageEndpoint()

DefaultMessageEndpoint

public DefaultMessageEndpoint(MessageHandler handler)

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface MessageEndpoint

setName

public void setName(java.lang.String name)

setBeanName

public void setBeanName(java.lang.String beanName)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

getHandler

public MessageHandler getHandler()

setHandler

public void setHandler(MessageHandler handler)

Set the handler to be invoked for each consumed message.

addMessageSelector

public void addMessageSelector(MessageSelector messageSelector)

getSubscription

public Subscription getSubscription()

Specified by:

getSubscription in interface MessageEndpoint

setSubscription

public void setSubscription(Subscription subscription)

getConcurrencyPolicy

public ConcurrencyPolicy getConcurrencyPolicy()

Specified by:

getConcurrencyPolicy in interface MessageEndpoint

setConcurrencyPolicy

public void setConcurrencyPolicy(ConcurrencyPolicy concurrencyPolicy)

setErrorHandler

public void setErrorHandler(ErrorHandler errorHandler)

hasErrorHandler

public boolean hasErrorHandler()

getDefaultOutputChannelName

public java.lang.String getDefaultOutputChannelName()

setDefaultOutputChannelName

public void setDefaultOutputChannelName(java.lang.String defaultOutputChannelName)

Set the name of the channel to which this endpoint can send reply messages by default.

setChannelRegistry

public void setChannelRegistry(ChannelRegistry channelRegistry)

Set the channel registry to use for looking up channels by name.

Specified by:

setChannelRegistry in interface ChannelRegistryAware

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

handle

public final Message<?> handle(Message<?> message)

Specified by:

handle in interface MessageHandler