diff options
| author | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-04 13:00:47 +0100 |
|---|---|---|
| committer | Francesco Mazzoli <francesco@rabbitmq.com> | 2012-09-04 13:00:47 +0100 |
| commit | e97a5d7653e72893865b6c87f47acfe0a7a07ecc (patch) | |
| tree | 7bcd40c9875e5ee3d2aea7f1ef6f07998b3d2b4b | |
| parent | 71285b38b5fcd6b8e4a076b43eba7360354c9991 (diff) | |
| download | rabbitmq-server-git-e97a5d7653e72893865b6c87f47acfe0a7a07ecc.tar.gz | |
was getting `set_length' instead of `drop'
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index dce69675ca..6f3d13826b 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -817,7 +817,7 @@ process_instruction({discard, ChPid, Msg = #basic_message { id = MsgId }}, {ok, State1 #state { sender_queues = SQ1, msg_id_status = MS1, backing_queue_state = BQS1 }}; -process_instruction({set_length, Length, Dropped, AckRequired}, +process_instruction({drop, Length, Dropped, AckRequired}, State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> QLen = BQ:len(BQS), |