From 582f67629dade0b53de266880e3a81f662dcd849 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Tue, 9 Mar 2010 20:06:25 +0000
Subject: [PATCH] INT-975 MessageHandler used in tests now implements the
 MessageProducer interface.

---
 .../handler/MessageHandlerChainTests.java       | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/handler/MessageHandlerChainTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/handler/MessageHandlerChainTests.java
index 8f1bed943e..b8a818d5b9 100644
--- a/org.springframework.integration/src/test/java/org/springframework/integration/handler/MessageHandlerChainTests.java
+++ b/org.springframework.integration/src/test/java/org/springframework/integration/handler/MessageHandlerChainTests.java
@@ -26,6 +26,7 @@ import org.junit.Test;
 import org.springframework.beans.factory.support.DefaultListableBeanFactory;
 import org.springframework.integration.core.Message;
 import org.springframework.integration.core.MessageChannel;
+import org.springframework.integration.core.MessageProducer;
 import org.springframework.integration.message.MessageBuilder;
 import org.springframework.integration.message.MessageHandler;
 
@@ -128,20 +129,22 @@ public class MessageHandlerChainTests {
 		chain.handleMessage(message);
 	}
 
-	private class ProducingHandlerStub implements MessageHandler {
-		private MessageChannel output;
-		
+
+	private static class ProducingHandlerStub implements MessageHandler, MessageProducer {
+
+		private volatile MessageChannel output;
+
 		private final MessageHandler messageHandler;
-		
+
 		public ProducingHandlerStub(MessageHandler handler) {
-			messageHandler = handler;
+			this.messageHandler = handler;
 		}
-		
+
 		public void setOutputChannel(MessageChannel channel) {
 			this.output = channel;
 			
 		}
-		
+
 		public void handleMessage(Message<?> message) {
 			messageHandler.handleMessage(message);
 			output.send(message);