diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-07-25 11:38:18 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-07-25 11:38:18 +0100 |
| commit | 5a4b32e1ccf37570973097086d4a07b6958207d1 (patch) | |
| tree | 90c7579b4ff65e1201530c3ad4df7ce7d1398687 | |
| parent | 767fc91fecc0ac98e9d6dd87257f4af18f138dfb (diff) | |
| download | rabbitmq-server-5a4b32e1ccf37570973097086d4a07b6958207d1.tar.gz | |
Remove some dead TODOs from when this was very young.
| -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 0610af65..7f0f0002 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", []). |