File tree Expand file tree Collapse file tree 2 files changed +4
-1
lines changed
src/test/java/com/rabbitmq/client/amqp/impl Expand file tree Collapse file tree 2 files changed +4
-1
lines changed Original file line number Diff line number Diff line change 2323import static com .rabbitmq .client .amqp .Management .QueueType .STREAM ;
2424import static com .rabbitmq .client .amqp .impl .Assertions .assertThat ;
2525import static com .rabbitmq .client .amqp .impl .TestConditions .BrokerVersion .RABBITMQ_4_0_3 ;
26+ import static com .rabbitmq .client .amqp .impl .TestConditions .BrokerVersion .RABBITMQ_4_2_0 ;
2627import static com .rabbitmq .client .amqp .impl .TestUtils .*;
2728import static com .rabbitmq .client .amqp .impl .Utils .threadFactory ;
2829import static java .nio .charset .StandardCharsets .*;
@@ -918,6 +919,7 @@ void messageAnnotationsSupportListMapArray() {
918919 "STREAM,true" ,
919920 "STREAM,false"
920921 })
922+ @ BrokerVersionAtLeast (RABBITMQ_4_2_0 )
921923 void explicitDurabilityShouldBeEnforced (Management .QueueType type , boolean durable ) {
922924 try {
923925 connection .management ().queue (this .name ).type (type ).declare ();
Original file line number Diff line number Diff line change @@ -35,7 +35,8 @@ private TestConditions() {}
3535
3636 public enum BrokerVersion {
3737 RABBITMQ_4_0_3 ("4.0.3" ),
38- RABBITMQ_4_1_0 ("4.1.0" );
38+ RABBITMQ_4_1_0 ("4.1.0" ),
39+ RABBITMQ_4_2_0 ("4.2.0" );
3940
4041 final String value ;
4142
You can’t perform that action at this time.
0 commit comments