diff options
| author | Alvaro Videla <alvaro@rabbitmq.com> | 2014-01-07 16:28:47 +0100 |
|---|---|---|
| committer | Alvaro Videla <alvaro@rabbitmq.com> | 2014-01-07 16:28:47 +0100 |
| commit | 373d51007ef017f48c42cbdf6de27a68cde9390d (patch) | |
| tree | f953ecfc289c11eafb4a0a0c56e8ed413907c434 | |
| parent | 0dfb3dae8fcf1b90f3d1382b3b6323a62256a035 (diff) | |
| download | rabbitmq-server-git-373d51007ef017f48c42cbdf6de27a68cde9390d.tar.gz | |
renames handle_expand_shortcuts to expand_shortcuts
| -rw-r--r-- | src/rabbit_channel.erl | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 9bd56d48ac..7d33bb827b 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -273,7 +273,7 @@ handle_cast({method, Method, Content, Flow}, noflow -> ok end, %% handle MRDQ before calling handle method - M = handle_expand_shortcuts(Method, State), + M = expand_shortcuts(Method, State), try handle_method(rabbit_channel_interceptor:intercept_method(M), Content, State) of {reply, Reply, NewState} -> @@ -557,44 +557,44 @@ expand_binding(queue, DestinationNameBin, RoutingKey, State) -> expand_binding(exchange, DestinationNameBin, RoutingKey, _) -> {DestinationNameBin, RoutingKey}. -handle_expand_shortcuts(#'basic.get'{queue = QueueNameBin} = Method, State) -> +expand_shortcuts(#'basic.get'{queue = QueueNameBin} = Method, State) -> setelement(#'basic.get'.queue, Method, expand_queue_name_shortcut(QueueNameBin, State)); -handle_expand_shortcuts(#'basic.consume'{queue = QueueNameBin} = Method, State) -> +expand_shortcuts(#'basic.consume'{queue = QueueNameBin} = Method, State) -> setelement(#'basic.consume'.queue, Method, expand_queue_name_shortcut(QueueNameBin, State)); -handle_expand_shortcuts(#'queue.delete'{queue = QueueNameBin} = Method, State) -> +expand_shortcuts(#'queue.delete'{queue = QueueNameBin} = Method, State) -> setelement(#'queue.delete'.queue, Method, expand_queue_name_shortcut(QueueNameBin, State)); -handle_expand_shortcuts(#'queue.purge'{queue = QueueNameBin} = Method, State) -> +expand_shortcuts(#'queue.purge'{queue = QueueNameBin} = Method, State) -> setelement(#'queue.purge'.queue, Method, expand_queue_name_shortcut(QueueNameBin, State)); -handle_expand_shortcuts(#'exchange.bind'{destination = DestinationNameBin, +expand_shortcuts(#'exchange.bind'{destination = DestinationNameBin, routing_key = RoutingKey} = Method, State) -> {DestinationName, ActualRoutingKey} = expand_binding(exchange, DestinationNameBin, RoutingKey, State), Method#'exchange.bind'{destination = DestinationName, routing_key = ActualRoutingKey}; -handle_expand_shortcuts(#'exchange.unbind'{destination = DestinationNameBin, +expand_shortcuts(#'exchange.unbind'{destination = DestinationNameBin, routing_key = RoutingKey} = Method, State) -> {DestinationName, ActualRoutingKey} = expand_binding(exchange, DestinationNameBin, RoutingKey, State), Method#'exchange.unbind'{destination = DestinationName, routing_key = ActualRoutingKey}; -handle_expand_shortcuts(#'queue.bind'{queue = QueueNameBin, +expand_shortcuts(#'queue.bind'{queue = QueueNameBin, routing_key = RoutingKey} = Method, State) -> {DestinationName, ActualRoutingKey} = expand_binding(queue, QueueNameBin, RoutingKey, State), Method#'queue.bind'{queue = DestinationName, routing_key = ActualRoutingKey}; -handle_expand_shortcuts(#'queue.unbind'{queue = QueueNameBin, +expand_shortcuts(#'queue.unbind'{queue = QueueNameBin, routing_key = RoutingKey} = Method, State) -> {DestinationName, ActualRoutingKey} = expand_binding(queue, QueueNameBin, RoutingKey, State), Method#'queue.bind'{queue = DestinationName, routing_key = ActualRoutingKey}; -handle_expand_shortcuts(M, _State) -> +expand_shortcuts(M, _State) -> M. |