diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-01-19 21:06:42 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-01-19 21:06:42 +0000 |
| commit | 8eb62868a8850707d05d0a40fc1f112373d9f3af (patch) | |
| tree | 20a18c4b1be568d353230f5e66bc89a3439d8998 | |
| parent | 25e0a6ef39d5151af66b128cffc65a9e4f0c05e5 (diff) | |
| download | rabbitmq-server-git-8eb62868a8850707d05d0a40fc1f112373d9f3af.tar.gz | |
no need to match on 'ok' twice
| -rw-r--r-- | src/rabbit_channel.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index aeb68ea69e..7e195d2fcb 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -533,16 +533,16 @@ handle_method(#'basic.recover'{requeue = false}, ok; ({DeliveryTag, ConsumerTag, {QName, QPid, MsgId, _Redelivered, Message}}, ok) -> - %% Was sent as a proper consumer delivery. Resend it as - %% before. + %% Was sent as a proper consumer delivery. Resend + %% it as before. %% %% FIXME: What should happen if the consumer's been %% cancelled since? %% %% FIXME: should we allocate a fresh DeliveryTag? - ok = internal_deliver( - WriterPid, false, ConsumerTag, DeliveryTag, - {QName, QPid, MsgId, true, Message}) + internal_deliver( + WriterPid, false, ConsumerTag, DeliveryTag, + {QName, QPid, MsgId, true, Message}) end, ok, UAMQ), %% No answer required, apparently! {noreply, State}; |