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

Stop channel adapter and reset conn between tests

Browse Source
This commit is contained in:
Artem Bilan
2020-10-08 13:27:13 -04:00
parent 04296664e3
commit 1df4f92cfd
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-integration-redis/src/test/java/org/springframework/integration/redis/inbound/ReactiveRedisStreamMessageProducerTests.java
View File

@@ -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() {