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);