File tree 1 file changed +4
-0
lines changed
src/test/java/com/rabbitmq/stream/perf
1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change 27
27
import com .rabbitmq .stream .impl .Client .StreamMetadata ;
28
28
import com .rabbitmq .stream .impl .Client .StreamParametersBuilder ;
29
29
import com .rabbitmq .stream .impl .TestUtils ;
30
+ import com .rabbitmq .stream .impl .TestUtils .BrokerVersion ;
31
+ import com .rabbitmq .stream .impl .TestUtils .BrokerVersionAtLeast ;
30
32
import com .rabbitmq .stream .impl .TestUtils .CallableConsumer ;
31
33
import com .rabbitmq .stream .impl .TestUtils .DisabledIfTlsNotEnabled ;
32
34
import java .io .BufferedReader ;
@@ -421,6 +423,8 @@ void shouldStopWhenTimeIsSet() throws Exception {
421
423
.isGreaterThanOrEqualTo (Duration .ofSeconds (3 ));
422
424
}
423
425
426
+ @ Test
427
+ @ BrokerVersionAtLeast (BrokerVersion .RABBITMQ_3_11 )
424
428
void singleActiveConsumersOnSuperStream () throws Exception {
425
429
String consumerName = "app-1" ;
426
430
Future <?> run =
You can’t perform that action at this time.
0 commit comments