Commit Graph

13 Commits

Author SHA1 Message Date
David Ansari 71d1b3b455 Respect message_interceptors.incoming.set_header_timestamp
When feature flag message_containers is enabled, setting
```
message_interceptors.incoming.set_header_timestamp
```
wasn't respected anymore when a message is published via MQTT to a
stream and subsequently consumed via AMQP 0.9.1.

This commit ensures that AMQP 0.9.1 header timestamp_in_ms will be
set.

Note that we must not modify the AMQP 1.0 properties section when messages
are received via AMQP 1.0 and consumed via AMQP 1.0.
Also, message annoation keys not starting with "x-" are reserved.
2024-04-10 11:40:49 +02:00
Rin Kuryloski 6c6f90916b Dedupe ?awaitMatch/4 in rabbit_assert.hrl 2024-03-13 11:41:00 +01:00
Michael Klishin 99968792fa Basic tests for the endpoints introduced in #8532 2023-06-14 03:14:36 +04:00
Alex Valiushko db99c252a0 Add setting to disable op policy edit via API 2023-02-06 14:36:10 -08:00
Michael Klishin 7c47d0925a
Revert "Correct a double quote introduced in #4603"
This reverts commit 6a44e0e2ef.

That wiped a lot of files unintentionally
2022-04-20 16:05:56 +04:00
Michael Klishin 6a44e0e2ef
Correct a double quote introduced in #4603 2022-04-20 16:01:29 +04:00
Philip Kuryloski dbb09f1bf5 Add ?awaitMatch/4 to rabbit_assert.hrl
?awaitMatch/4 is the same as ?awaitMatch/3, but where the polling
interval is configurable
2021-07-05 15:21:27 +02:00
Philip Kuryloski f8c09121c1 Revert "Add ?awaitMatch/4 to rabbit_assert.hrl"
This reverts commit 3bb9d0084d.
2021-07-05 11:46:51 +02:00
Philip Kuryloski 3bb9d0084d Add ?awaitMatch/4 to rabbit_assert.hrl
?awaitMatch/4 is the same as ?awaitMatch/3, but where the polling
interval is configurable
2021-07-05 11:40:42 +02:00
Philip Kuryloski 0236c64ace Reduce chances of variable capture in ?awaitMatch
Attempt to name all of the variables in the macro such that they are less
likely to collide with any existing bindings.
2020-07-06 12:08:23 +02:00
Philip Kuryloski 9479c2e9cc Add ?awaitMatch macro
awaitMatch(Guard, Expr, Timeout) reevaluates Expr until it matches
Guard up to Timeout milliseconds from now. It returns the matched
value, in the event said value is useful later in a test.

Additionally simplify an instance of ?assertEqual(true, ... to ?assert(
2020-07-02 11:33:17 +02:00
Daniil Fedotov c3f2bc70f7 Post-merge fixes 2017-05-03 13:55:24 +01:00
Daniil Fedotov ca42aa2db9 Move management test helpers here to test management plugins 2017-04-28 12:27:52 +01:00