diff options
| -rw-r--r-- | src/rabbit_channel.erl | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 0610af653e..7f0f0002ca 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -501,7 +501,6 @@ check_name(Kind, NameBin = <<"amq.", _/binary>>) -> check_name(_Kind, NameBin) -> NameBin. -%% TODO port this(?) queue_blocked(QPid, State = #ch{blocking = Blocking}) -> case dict:find(QPid, Blocking) of error -> State; @@ -1131,15 +1130,6 @@ handle_method(#'basic.credit'{consumer_tag = CTag, State1 = State#ch{limiter_pid = LimiterPid2}, return_ok(State1, false, #'basic.credit_ok'{available = Available}); - %% TODO port this bit ? - %% case consumer_queues(Consumers) of - %% [] -> {reply, #'channel.flow_ok'{active = false}, State1}; - %% QPids -> Queues = [{QPid, erlang:monitor(process, QPid)} || - %% QPid <- QPids], - %% ok = rabbit_amqqueue:flush_all(QPids, self()), - %% {noreply, State1#ch{blocking = dict:from_list(Queues)}} - %% end; - handle_method(_MethodRecord, _Content, _State) -> rabbit_misc:protocol_error( command_invalid, "unimplemented method", []). |