Merge pull request #298 from olegz/INT-2358

* INT-2358:
  INT-2358
This commit is contained in:
Mark Fisher
2012-01-05 09:42:00 -05:00

View File

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