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 23
23
import static com .rabbitmq .client .amqp .Management .QueueType .STREAM ;
24
24
import static com .rabbitmq .client .amqp .impl .Assertions .assertThat ;
25
25
import 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 ;
26
27
import static com .rabbitmq .client .amqp .impl .TestUtils .*;
27
28
import static com .rabbitmq .client .amqp .impl .Utils .threadFactory ;
28
29
import static java .nio .charset .StandardCharsets .*;
@@ -918,6 +919,7 @@ void messageAnnotationsSupportListMapArray() {
918
919
"STREAM,true" ,
919
920
"STREAM,false"
920
921
})
922
+ @ BrokerVersionAtLeast (RABBITMQ_4_2_0 )
921
923
void explicitDurabilityShouldBeEnforced (Management .QueueType type , boolean durable ) {
922
924
try {
923
925
connection .management ().queue (this .name ).type (type ).declare ();
Original file line number Diff line number Diff line change @@ -35,7 +35,8 @@ private TestConditions() {}
35
35
36
36
public enum BrokerVersion {
37
37
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" );
39
40
40
41
final String value ;
41
42
You can’t perform that action at this time.
0 commit comments