org.springframework.integration.endpoint
Class AbstractEndpoint
java.lang.Object
org.springframework.integration.endpoint.AbstractEndpoint
- All Implemented Interfaces:
- org.springframework.beans.factory.BeanNameAware, MessageEndpoint, MessageTarget
- Direct Known Subclasses:
- AbstractRequestReplyEndpoint, InboundChannelAdapter, OutboundChannelAdapter
public abstract class AbstractEndpoint
- extends java.lang.Object
- implements MessageEndpoint, org.springframework.beans.factory.BeanNameAware
The base class for Message Endpoint implementations.
- Author:
- Mark Fisher
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
logger
protected final org.apache.commons.logging.Log logger
name
private volatile java.lang.String name
source
private MessageSource<?> source
target
private MessageTarget target
schedule
private volatile Schedule schedule
errorHandler
private volatile ErrorHandler errorHandler
messageExchangeTemplate
private final MessageExchangeTemplate messageExchangeTemplate
AbstractEndpoint
public AbstractEndpoint()
getName
public java.lang.String getName()
- Return the name of this endpoint.
- Specified by:
getName
in interface MessageEndpoint
setBeanName
public void setBeanName(java.lang.String name)
- Specified by:
setBeanName
in interface org.springframework.beans.factory.BeanNameAware
getSource
public MessageSource<?> getSource()
- Specified by:
getSource
in interface MessageEndpoint
setSource
public void setSource(MessageSource<?> source)
- Specified by:
setSource
in interface MessageEndpoint
getTarget
public MessageTarget getTarget()
- Specified by:
getTarget
in interface MessageEndpoint
setTarget
public void setTarget(MessageTarget target)
- Specified by:
setTarget
in interface MessageEndpoint
getSchedule
public Schedule getSchedule()
- Specified by:
getSchedule
in interface MessageEndpoint
setSchedule
public void setSchedule(Schedule schedule)
- Specified by:
setSchedule
in interface MessageEndpoint
getMessageExchangeTemplate
protected MessageExchangeTemplate getMessageExchangeTemplate()
setErrorHandler
public void setErrorHandler(ErrorHandler errorHandler)
- Provide an error handler for any Exceptions that occur
upon invocation of this endpoint. If none is provided,
the Exception messages will be logged (at warn level),
and the Exception rethrown.
send
public final boolean send(Message<?> message)
- Description copied from interface:
MessageTarget
- Send a
Message
to this target. May throw a RuntimeException for non-recoverable
errors. Otherwise, if the Message cannot be sent for a non-fatal reason such as timeout,
then this method will return 'false', and if the Message is sent successfully, it will
return 'true'.
- Specified by:
send
in interface MessageTarget
- Parameters:
message
- the Message to send
- Returns:
- whether the Message has been sent successfully
sendInternal
protected abstract boolean sendInternal(Message<?> message)
handleException
private void handleException(MessagingException exception)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object