From 1df4f92cfd8131d7d44f78b602cd1feef02a6140 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@vmware.com>
Date: Thu, 8 Oct 2020 13:27:13 -0400
Subject: [PATCH] Stop channel adapter and reset conn between tests

---
 .../inbound/ReactiveRedisStreamMessageProducerTests.java   | 7 +++++++
 1 file changed, 7 insertions(+)

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 ae5af17703..881259bcb1 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
@@ -22,6 +22,7 @@ import static org.awaitility.Awaitility.await;
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicReference;
 
+import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -97,6 +98,12 @@ public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests
 		this.template.delete(STREAM_KEY).block();
 	}
 
+	@After
+	public void tearDown() {
+		this.redisStreamMessageProducer.stop();
+		RedisAvailableRule.connectionFactory.resetConnection();
+	}
+
 	@Test
 	@RedisAvailable
 	public void testConsumerGroupCreation() {