diff options
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index f56cf5b3af..bb12cf491a 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -219,5 +219,8 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, BQS1 = BQ:publish(Msg, Props1, true, none, BQS), slave_sync_loop(Args, TRef, BQS1); {'EXIT', Parent, Reason} -> - {stop, Reason, {TRef, BQS}} + {stop, Reason, {TRef, BQS}}; + {'$gen_cast', {gm, {delete_and_terminate, Reason}}} -> + BQS1 = BQ:delete_and_terminate(Reason, BQS), + {stop, Reason, {TRef, BQS1}} end. |