Skip to content

Commit d25e2df

Browse files
committed
Expect AMQP 091 LongString from AMQP 1.0 binary
References rabbitmq/rabbitmq-server#11715
1 parent a5f24a3 commit d25e2df

File tree

1 file changed

+1
-9
lines changed

1 file changed

+1
-9
lines changed

src/test/java/com/rabbitmq/stream/impl/AmqpInteroperabilityTest.java

+1-9
Original file line numberDiff line numberDiff line change
@@ -577,15 +577,7 @@ void publishToStreamConsumeFromStreamQueue(Codec codec, TestInfo info) {
577577
mb.applicationProperties()
578578
.entry("binary", "hello".getBytes(UTF8)),
579579
d -> {
580-
// TODO leave only LongString expectation once 3.13.5 is out
581-
Object binary = d.getProperties().getHeaders().get("binary");
582-
Object expected;
583-
if (binary instanceof LongString) {
584-
// 3.13.5+
585-
expected = LongStringHelper.asLongString("hello");
586-
} else {
587-
expected = "hello".getBytes(UTF8);
588-
}
580+
LongString expected = LongStringHelper.asLongString("hello");
589581
assertThat(d.getProperties().getHeaders())
590582
.containsEntry("binary", expected);
591583
}));

0 commit comments

Comments
 (0)