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 | c4d78500e17f080300710a9e36dcb85740c13675 (patch) | |
| tree | 7bcd40c9875e5ee3d2aea7f1ef6f07998b3d2b4b | |
| parent | 5794c238301c46b57d2c3e849b52f022f0e482e6 (diff) | |
| download | rabbitmq-server-c4d78500e17f080300710a9e36dcb85740c13675.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 dce69675..6f3d1382 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), |