From 68379b6fb1e4efc606cb6d8e2686b19bcef851c4 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 8 Oct 2020 10:35:26 -0400 Subject: [PATCH] Some Redis Streams tests improvements --- .../ReactiveRedisStreamMessageProducerTests.java | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java index de74e16f4c..d21c513fa6 100644 --- a/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java +++ b/spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java @@ -132,7 +132,7 @@ public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests this.redisStreamMessageProducer.setCreateConsumerGroup(false); this.redisStreamMessageProducer.setConsumerName(null); - this.redisStreamMessageProducer.setReadOffset(ReadOffset.from("0")); + this.redisStreamMessageProducer.setReadOffset(ReadOffset.from("0-0")); this.redisStreamMessageProducer.afterPropertiesSet(); StepVerifier stepVerifier = @@ -191,14 +191,7 @@ public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests Address address = new Address("Winterfell, Westeros"); Person person = new Person(address, "John Snow"); - this.template.opsForStream() - .createGroup(STREAM_KEY, this.redisStreamMessageProducer.getBeanName()) - .as(StepVerifier::create) - .assertNext(message -> assertThat(message).isEqualTo("OK")) - .thenCancel() - .verify(Duration.ofSeconds(10)); - - this.redisStreamMessageProducer.setCreateConsumerGroup(false); + this.redisStreamMessageProducer.setCreateConsumerGroup(true); this.redisStreamMessageProducer.setAutoAck(false); this.redisStreamMessageProducer.setConsumerName(CONSUMER); this.redisStreamMessageProducer.setReadOffset(ReadOffset.latest());