diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-09-05 10:41:13 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-09-05 10:41:13 +0100 |
| commit | 31be44cec399122124c16df17baa9f6aa83a9fa5 (patch) | |
| tree | f8fbb7bf95a3ef7bb7789b8d51078a1ca9a79895 /src | |
| parent | 170fa80089f4c31072e2313596ed721bde0f276b (diff) | |
| download | rabbitmq-server-git-31be44cec399122124c16df17baa9f6aa83a9fa5.tar.gz | |
Gah
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 3 |
2 files changed, 2 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 473d96716e..8b71060c4b 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -117,8 +117,7 @@ stop_mirroring(State = #state { coordinator = CPid, {BQ, BQS}. terminate({shutdown, dropped} = Reason, - State = #state { gm = GM, - backing_queue = BQ, + State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> %% Backing queue termination - this node has been explicitly %% dropped. Normally, non-durable queues would be tidied up on diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index f245f91310..9a4d5cbef2 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -293,8 +293,7 @@ terminate(_Reason, #state { backing_queue_state = undefined }) -> %% We've received a delete_and_terminate from gm, thus nothing to %% do here. ok; -terminate({shutdown, dropped} = R, #state { gm = GM, - backing_queue = BQ, +terminate({shutdown, dropped} = R, #state { backing_queue = BQ, backing_queue_state = BQS }) -> %% See rabbit_mirror_queue_master:terminate/2 BQ:delete_and_terminate(R, BQS); |