SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add support for durable subscriptions in Redis

Browse Source
This commit is contained in:
Marius Bogoevici
2016-01-29 19:04:12 -05:00
parent 73abe565fd
commit 31961ae595
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream-binders/spring-cloud-stream-binder-redis/src/main/java/org/springframework/cloud/stream/binder/redis/RedisMessageChannelBinder.java
View File

@@ -85,6 +85,7 @@ public class RedisMessageChannelBinder extends MessageChannelBinderSupport imple
.addAll(CONSUMER_RETRY_PROPERTIES)
.add(BinderPropertyKeys.CONCURRENCY)
.add(BinderPropertyKeys.PARTITION_INDEX)
.add(BinderPropertyKeys.DURABLE)
.build();
/**
@@ -250,7 +251,10 @@ public class RedisMessageChannelBinder extends MessageChannelBinderSupport imple
protected void afterUnbind(Binding<MessageChannel> binding) {
if (Binding.Type.consumer.equals(binding.getType())) {
String key = CONSUMER_GROUPS_KEY_PREFIX + binding.getName();
this.redisOperations.boundZSetOps(key).incrementScore(binding.getGroup(), -1);
boolean durable = binding.getPropertiesAccessor().isDurable(defaultDurableSubscription);
if (!durable) {
this.redisOperations.boundZSetOps(key).incrementScore(binding.getGroup(), -1);
}
}
}