We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 101b906 commit 6400d49Copy full SHA for 6400d49
src/test/java/com/rabbitmq/stream/impl/StreamConsumerTest.java
@@ -51,7 +51,6 @@
51
import java.util.stream.Stream;
52
import org.junit.jupiter.api.AfterEach;
53
import org.junit.jupiter.api.BeforeEach;
54
-import org.junit.jupiter.api.Disabled;
55
import org.junit.jupiter.api.Test;
56
import org.junit.jupiter.api.TestInfo;
57
import org.junit.jupiter.api.extension.ExtendWith;
@@ -332,7 +331,6 @@ void manualTrackingConsumerShouldRestartWhereItLeftOff() throws Exception {
332
331
333
@Test
334
@DisabledIfRabbitMqCtlNotSet
335
- @Disabled
336
void consumerShouldReUseInitialOffsetSpecificationAfterDisruptionIfNoMessagesReceived()
337
throws Exception {
338
int messageCountFirstWave = 10_000;
0 commit comments