diff options
| author | Michael Bridgen <mikeb@lshift.net> | 2009-11-17 16:56:20 +0000 |
|---|---|---|
| committer | Michael Bridgen <mikeb@lshift.net> | 2009-11-17 16:56:20 +0000 |
| commit | 6e59f6bb13d5d457ffdf095bc73808c76164fe51 (patch) | |
| tree | dd49428b14f3105822e7f2c57f8b09e8d0010968 | |
| parent | be0f4ad53d7a365686eef57e9f7edb157d9c98f4 (diff) | |
| download | rabbitmq-server-git-6e59f6bb13d5d457ffdf095bc73808c76164fe51.tar.gz | |
Bug 21986: Implement synchronous basic.recover
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 759840aad1..d525f9415a 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -556,6 +556,14 @@ handle_method(#'basic.recover_async'{}, _, _State) -> rabbit_misc:protocol_error( not_allowed, "attempt to recover a transactional channel",[]); +handle_method(#'basic.recover'{requeue = Requeue}, Content, State) -> + {noreply, State2 = #ch{writer_pid = WriterPid}} = + handle_method(#'basic.recover_async'{requeue = Requeue}, + Content, + State), + ok = rabbit_writer:send_command(WriterPid, #'basic.recover_ok'{}), + {noreply, State2}; + handle_method(#'exchange.declare'{exchange = ExchangeNameBin, type = TypeNameBin, passive = false, |