diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2013-04-16 12:45:12 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2013-04-16 12:45:12 +0100 |
| commit | 2677e563f4086168b6ab0345c93e707c964259a6 (patch) | |
| tree | 514e227787c5e6a0d197c485b7db7bacff870a2a | |
| parent | 4c34dc69c16181f0600862d56fafe98cd09d4fd2 (diff) | |
| download | rabbitmq-server-git-2677e563f4086168b6ab0345c93e707c964259a6.tar.gz | |
Further excisions
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 7ab0d7742d..3712a62581 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -49,7 +49,6 @@ ttl_timer_ref, ttl_timer_expiry, senders, - queue_monitors, dlx, dlx_routing_key, max_length, @@ -831,9 +830,8 @@ dead_letter_publish(Msg, Reason, X, RK, QName) -> {Queues, Cycles} = detect_dead_letter_cycles( DLMsg, rabbit_exchange:route(X, Delivery)), lists:foreach(fun log_cycle_once/1, Cycles), - {_, DeliveredQPids} = rabbit_amqqueue:deliver( - rabbit_amqqueue:lookup(Queues), Delivery), - DeliveredQPids. + rabbit_amqqueue:deliver( rabbit_amqqueue:lookup(Queues), Delivery), + ok. stop(State) -> stop(noreply, State). |