Skip to content

Commit 0f0dc2c

Browse files
committed
Use AMQP expiration header as TTL in interop tests
And not as a timestamp. A limit has been set on the broker side, so using a timestamp triggers a validation error now. References rabbitmq/rabbitmq-server#4836
1 parent 5f9c461 commit 0f0dc2c

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,10 +103,10 @@ void publishToStreamQueueConsumeFromStream(Codec codec) throws Exception {
103103
assertThat(m.getMessageAnnotations().get("x-basic-delivery-mode"))
104104
.isEqualTo(UnsignedByte.valueOf("2"))),
105105
ptc(
106-
b -> b.expiration(String.valueOf(timestamp.getTime() * 2)),
106+
b -> b.expiration(String.valueOf(60_000)),
107107
m ->
108108
assertThat(m.getMessageAnnotations().get("x-basic-expiration"))
109-
.isEqualTo(String.valueOf(timestamp.getTime() * 2))),
109+
.isEqualTo(String.valueOf(60_000))),
110110
ptc(
111111
b -> b.messageId("message id"),
112112
m ->

0 commit comments

Comments
 (0)