AFTER_EACH_TEST_METHOD for Redis Streams tests

This commit is contained in:
Artem Bilan
2020-10-08 11:26:49 -04:00
parent dbbd855fb8
commit 6c2498de34

View File

@@ -22,7 +22,6 @@ 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;
@@ -64,7 +63,7 @@ import reactor.test.StepVerifier;
* @since 5.4
*/
@RunWith(SpringRunner.class)
@DirtiesContext
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests {
private static final String STREAM_KEY = "myStream";
@@ -98,11 +97,6 @@ public class ReactiveRedisStreamMessageProducerTests extends RedisAvailableTests
this.template.delete(STREAM_KEY).block();
}
@After
public void tearDown() {
this.redisStreamMessageProducer.stop();
}
@Test
@RedisAvailable
public void testConsumerGroupCreation() {