Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-2358

Browse Source 
added Lifecycle method implementations to RedisInboundChannelAdapter
This commit is contained in:
Oleg Zhurakousky
2012-01-05 07:57:52 -05:00
committed by Mark Fisher
parent 770b4c22db
commit 05e9828a6b
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-integration-redis/src/main/java/org/springframework/integration/redis/inbound/RedisInboundChannelAdapter.java
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);