fix pattern match

(cherry picked from commit 46e8f9a)
(cherry picked from commit e148941)

Author: kjnilsson

deps/rabbit/src/rabbit_fifo_dlx_worker.erl

@@ -135,7 +135,7 @@ handle_call(Request, From, State) ->
     rabbit_log:info("~s received unhandled call from ~p: ~p", [?MODULE, From, Request]),
     {noreply, State}.
 
-handle_cast({dlx_event, _LeaderPid, {machine, lookup_topology}},
+handle_cast({dlx_event, _LeaderPid, lookup_topology},
             #state{queue_ref = _} = State0) ->
     State = lookup_topology(State0),
     redeliver_and_ack(State);

deps/rabbit/test/rabbit_fifo_dlx_integration_SUITE.erl

@@ -587,7 +587,8 @@ reject_publish(Config, QArg) when is_tuple(QArg) ->
     ok = publish_confirm(Ch, SourceQ),
     RaName = ra_name(SourceQ),
     eventually(?_assertMatch([{2, 2}], %% 2 messages with 1 byte each
-                             dirty_query([Server], RaName, fun rabbit_fifo:query_stat_dlx/1))),
+                             dirty_query([Server], RaName,
+                                         fun rabbit_fifo:query_stat_dlx/1))),
     %% Now, we have 2 expired messages in the source quorum queue's discards queue.
     %% Now that we are over the limit we expect publishes to be rejected.
     ?assertEqual(fail, publish_confirm(Ch, SourceQ)),