From dc3ff10b429e3f9782cf7e305c4de9ddd68e64e2 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Sun, 16 Dec 2007 18:24:09 +0000 Subject: [PATCH] AbstractChannelAdatper is now BeanNameAware --- .../endpoint/AbstractChannelAdapter.java | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractChannelAdapter.java b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractChannelAdapter.java index 0127e0c352..6bf848591d 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractChannelAdapter.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractChannelAdapter.java @@ -26,7 +26,7 @@ import java.util.concurrent.TimeoutException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; - +import org.springframework.beans.factory.BeanNameAware; import org.springframework.beans.factory.InitializingBean; import org.springframework.integration.MessageHandlingException; import org.springframework.integration.channel.MessageChannel; @@ -40,15 +40,30 @@ import org.springframework.util.Assert; * * @author Mark Fisher */ -public abstract class AbstractChannelAdapter implements MessageChannel, InitializingBean { +public abstract class AbstractChannelAdapter implements MessageChannel, InitializingBean, BeanNameAware { protected Log logger = LogFactory.getLog(this.getClass()); + private String name; + private MessageMapper mapper = new SimplePayloadMessageMapper(); private volatile boolean initialized; + + public void setName(String name) { + this.name = name; + } + + public String getName() { + return this.name; + } + + public void setBeanName(String beanName) { + this.setName(beanName); + } + public final void afterPropertiesSet() { this.initialize(); this.initialized = true;