diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 13 | ||||
| -rw-r--r-- | src/rabbit_exchange.erl | 1 |
2 files changed, 2 insertions, 12 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 75e050951a..a96c914a4c 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -163,18 +163,9 @@ start_queue_process(Q) -> recover_queue(Q) -> ok = store_queue(Q), %ok = recover_bindings(Q), + % This is where the default binding should be added ok. - -update_bindings(Q = #amqqueue{}, Spec, - UpdateSpecFun, UpdateExchangeFun) -> - exit(update_bindings). - % Q1 = Q#amqqueue{binding_specs = UpdateSpecFun(Spec, Specs0)}, - % case UpdateExchangeFun(Spec, Q1) of - % ok -> store_queue(Q1), - % {ok, Q1}; - % Other -> Other - % end. - + add_binding(QueueName, ExchangeName, RoutingKey, Arguments) -> % Since this calls straight through to rabbit_exchange, % can this exported function be deleted from this module? diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index dd9a60a020..1e17f9d3c7 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -195,7 +195,6 @@ route_internal(#resource{name = Name, virtual_host = VHostPath}, RoutingKey) -> MatchHead = #route{binding = #binding{exchange_name = '$1', queue_name = '$2', key = '$3'}}, - %MatchHead = #person{name='$1', sex=male, age='$2', _='_'}, Guards = [{'==', '$1', Name}, {'==', '$3', RoutingKey}], lookup_qpids( mnesia:activity(async_dirty, |