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, MessageTarget

Direct Known Subclasses:

HandlerEndpoint

public class TargetEndpoint
extends AbstractEndpoint

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

Author:

Mark Fisher

Field Summary

private java.lang.Object	initializationMonitor
private boolean	initialized
private long	receiveTimeout
private MessageSelector	selector
private long	sendTimeout
private MessageTarget	target

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

logger

Constructor Summary

TargetEndpoint()

TargetEndpoint(MessageTarget target)

Method Summary

MessageTarget	getTarget()
protected boolean	handleMessage(Message<?> message)
protected void	initialize()
boolean	poll()
void	setMessageSelector(MessageSelector selector)
void	setReceiveTimeout(long receiveTimeout)
void	setSendTimeout(long sendTimeout)
void	setTarget(MessageTarget target)
protected boolean	supports(Message<?> message)

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

addInterceptor, afterPropertiesSet, getChannelRegistry, getInputChannel, getInputChannelName, getInterceptors, getName, getOutputChannel, getOutputChannelName, getSchedule, getTrigger, isRunning, send, setAutoStartup, setBeanName, setChannelRegistry, setInputChannel, setInputChannelName, setInterceptors, setName, setOutputChannel, setOutputChannelName, setSchedule, setTrigger, start, stop, toString

Methods inherited from class java.lang.Object

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

Field Detail

target

private volatile MessageTarget target

selector

private volatile MessageSelector selector

receiveTimeout

private volatile long receiveTimeout

sendTimeout

private volatile long sendTimeout

initialized

private volatile boolean initialized

initializationMonitor

private final java.lang.Object initializationMonitor

Constructor Detail

TargetEndpoint

public TargetEndpoint()

TargetEndpoint

public TargetEndpoint(MessageTarget target)

Method Detail

getTarget

public MessageTarget getTarget()

setTarget

public void setTarget(MessageTarget target)

setMessageSelector

public void setMessageSelector(MessageSelector selector)

setReceiveTimeout

public void setReceiveTimeout(long receiveTimeout)

setSendTimeout

public void setSendTimeout(long sendTimeout)

initialize

protected void initialize()

Overrides:

initialize in class AbstractEndpoint

supports

protected boolean supports(Message<?> message)

Specified by:

supports in class AbstractEndpoint

handleMessage

protected final boolean handleMessage(Message<?> message)

Specified by:

handleMessage in class AbstractEndpoint

poll

public final boolean poll()