From 05e9828a6b36ce794d94d387decdc4e3e261378d Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Thu, 5 Jan 2012 07:57:52 -0500
Subject: [PATCH] INT-2358

added Lifecycle method implementations to RedisInboundChannelAdapter
---
 .../redis/inbound/RedisInboundChannelAdapter.java | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/RedisInboundChannelAdapter.java b/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/RedisInboundChannelAdapter.java
index f822afc934..83f3c3955a 100644
--- a/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/RedisInboundChannelAdapter.java
+++ b/spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/RedisInboundChannelAdapter.java
@@ -1,5 +1,5 @@
 /*
- * Copyright 2007-2011 the original author or authors
+ * Copyright 2007-2012 the original author or authors
  *
  *     Licensed under the Apache License, Version 2.0 (the "License");
  *     you may not use this file except in compliance with the License.
@@ -78,6 +78,19 @@ public class RedisInboundChannelAdapter extends MessageProducerSupport {
 		this.container.addMessageListener(adapter, topicList);
 		this.container.afterPropertiesSet();
 	}
+	
+	@Override
+	protected void doStart() {
+		super.doStart();
+		this.container.start();
+	}
+
+	
+	@Override
+	protected void doStop() {
+		super.doStop();
+		this.container.stop();
+	}
 
 	private Message<?> convertMessage(String s) {
 		return this.messageConverter.toMessage(s);