Skip to content

Commit 886b655

Browse files
committed
Enable 'remove' consumer cancel mode for AMQP
1 parent 557b02d commit 886b655

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

deps/rabbit/src/rabbit_amqp_session.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1151,6 +1151,7 @@ handle_control(Detach = #'v1_0.detach'{handle = ?UINT(HandleInt)},
11511151
%% becomes available for re-use once a link is closed): This will result in the same consumer tag,
11521152
%% and we ideally disallow "updating" an AMQP consumer.
11531153
Spec = #{consumer_tag => Ctag,
1154+
reason => remove,
11541155
user => Username},
11551156
case rabbit_queue_type:cancel(Q, Spec, QStates0) of
11561157
{ok, QStates1} ->

0 commit comments

Comments
 (0)