org.springframework.integration.endpoint
Class TargetEndpoint

java.lang.Object
  org.springframework.integration.endpoint.AbstractEndpoint
      org.springframework.integration.endpoint.TargetEndpoint

All Implemented Interfaces:

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

Direct Known Subclasses:

HandlerEndpoint

public class TargetEndpoint
extends AbstractEndpoint
implements Target, ChannelRegistryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle

Base class for MessageEndpoint implementations to which Messages may be sent.

Author:

Mark Fisher

Field Summary

private ChannelRegistry	channelRegistry
private ConcurrencyPolicy	concurrencyPolicy
private ErrorHandler	errorHandler
private boolean	initialized
private boolean	running
private MessageSelector	selector
private Subscription	subscription
private Target	target

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

logger

Constructor Summary

TargetEndpoint()

TargetEndpoint(Target target)

Method Summary

void	afterPropertiesSet()
protected ChannelRegistry	getChannelRegistry()
ConcurrencyPolicy	getConcurrencyPolicy()
Subscription	getSubscription()
Target	getTarget()
boolean	hasErrorHandler()
boolean	isRunning()
boolean	send(Message<?> message)
void	setChannelRegistry(ChannelRegistry channelRegistry) Set the channel registry to use for looking up channels by name.
void	setConcurrencyPolicy(ConcurrencyPolicy concurrencyPolicy)
void	setErrorHandler(ErrorHandler errorHandler)
void	setMessageSelector(MessageSelector selector)
void	setSubscription(Subscription subscription)
void	setTarget(Target target)
void	start()
void	stop()

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

getName, setBeanName, setName, toString

Methods inherited from class java.lang.Object

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

Field Detail

target

private volatile Target target

subscription

private volatile Subscription subscription

concurrencyPolicy

private volatile ConcurrencyPolicy concurrencyPolicy

errorHandler

private volatile ErrorHandler errorHandler

selector

private volatile MessageSelector selector

channelRegistry

private volatile ChannelRegistry channelRegistry

initialized

private volatile boolean initialized

running

private volatile boolean running

Constructor Detail

TargetEndpoint

public TargetEndpoint()

TargetEndpoint

public TargetEndpoint(Target target)

Method Detail

getTarget

public Target getTarget()

setTarget

public void setTarget(Target target)

setMessageSelector

public void setMessageSelector(MessageSelector selector)

getSubscription

public Subscription getSubscription()

setSubscription

public void setSubscription(Subscription subscription)

getConcurrencyPolicy

public ConcurrencyPolicy getConcurrencyPolicy()

setConcurrencyPolicy

public void setConcurrencyPolicy(ConcurrencyPolicy concurrencyPolicy)

setErrorHandler

public void setErrorHandler(ErrorHandler errorHandler)

hasErrorHandler

public boolean hasErrorHandler()

setChannelRegistry

public void setChannelRegistry(ChannelRegistry channelRegistry)

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

Specified by:

setChannelRegistry in interface ChannelRegistryAware

getChannelRegistry

protected ChannelRegistry getChannelRegistry()

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

send

public final boolean send(Message<?> message)

Specified by:

send in interface Target