diff options
| author | Michael Klishin <klishinm@vmware.com> | 2023-05-15 18:13:40 +0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-05-15 18:13:40 +0400 |
| commit | 42dbaf8fa6c8e2c310ac4f802887780d2e9e2bb8 (patch) | |
| tree | 94399c7106121c5327670d5802b4aac5c40948aa /deps/rabbit/src/rabbit_channel.erl | |
| parent | 1ee8454129b7769fda6dfc1a528e886b290aa258 (diff) | |
| parent | ddabc3519117c1556ef1a5467931242d07e5f425 (diff) | |
| download | rabbitmq-server-git-42dbaf8fa6c8e2c310ac4f802887780d2e9e2bb8.tar.gz | |
Merge pull request #8188 from rabbitmq/message-interceptor
Move plugin rabbitmq-message-timestamp to the core
Diffstat (limited to 'deps/rabbit/src/rabbit_channel.erl')
| -rw-r--r-- | deps/rabbit/src/rabbit_channel.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/deps/rabbit/src/rabbit_channel.erl b/deps/rabbit/src/rabbit_channel.erl index 666d6e88d6..a78b8e1c08 100644 --- a/deps/rabbit/src/rabbit_channel.erl +++ b/deps/rabbit/src/rabbit_channel.erl @@ -1288,9 +1288,10 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin, check_write_permitted_on_topic(Exchange, User, RoutingKey, AuthzContext), %% We decode the content's properties here because we're almost %% certain to want to look at delivery-mode and priority. - DecodedContent = #content {properties = Props} = + DecodedContent0 = #content {properties = Props} = maybe_set_fast_reply_to( rabbit_binary_parser:ensure_content_decoded(Content), State), + DecodedContent = rabbit_message_interceptor:intercept(DecodedContent0), check_user_id_header(Props, State), check_expiration_header(Props), DoConfirm = Tx =/= none orelse ConfirmEnabled, |