diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-01-09 13:12:11 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-01-09 13:12:11 +0000 |
| commit | b033a551918b101b4dfc3d422a0ad32c3501b6ad (patch) | |
| tree | 0f2aaf3c1be45c5d9109c3d23fd2122038fb514c | |
| parent | 12a1bdca454231ad355c63c9773c099ed5909eaf (diff) | |
| download | rabbitmq-server-git-b033a551918b101b4dfc3d422a0ad32c3501b6ad.tar.gz | |
Verticality
| -rw-r--r-- | src/rabbit_channel.erl | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 78826554ef..bd9d76323a 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -546,20 +546,20 @@ expand_routing_key_shortcut(<<>>, <<>>, expand_routing_key_shortcut(_QueueNameBin, RoutingKey, _State) -> RoutingKey. -expand_shortcuts(#'basic.get'{queue = QName} = M, State) -> - M#'basic.get'{queue = expand_queue_name_shortcut(QName, State)}; -expand_shortcuts(#'basic.consume'{queue = QName} = M, State) -> - M#'basic.consume'{queue = expand_queue_name_shortcut(QName, State)}; -expand_shortcuts(#'queue.delete'{queue = QName} = M, State) -> - M#'queue.delete'{queue = expand_queue_name_shortcut(QName, State)}; -expand_shortcuts(#'queue.purge'{queue = QName} = M, State) -> - M#'queue.purge'{queue = expand_queue_name_shortcut(QName, State)}; -expand_shortcuts(#'queue.bind'{queue = Q, routing_key = K} = M, State) -> - M#'queue.bind'{queue = expand_queue_name_shortcut(Q, State), - routing_key = expand_routing_key_shortcut(Q, K, State)}; -expand_shortcuts(#'queue.unbind'{queue = Q, routing_key = K} = M, State) -> - M#'queue.bind'{queue = expand_queue_name_shortcut(Q, State), - routing_key = expand_routing_key_shortcut(Q, K, State)}; +expand_shortcuts(#'basic.get' {queue = Q} = M, State) -> + M#'basic.get' {queue = expand_queue_name_shortcut(Q, State)}; +expand_shortcuts(#'basic.consume'{queue = Q} = M, State) -> + M#'basic.consume'{queue = expand_queue_name_shortcut(Q, State)}; +expand_shortcuts(#'queue.delete' {queue = Q} = M, State) -> + M#'queue.delete' {queue = expand_queue_name_shortcut(Q, State)}; +expand_shortcuts(#'queue.purge' {queue = Q} = M, State) -> + M#'queue.purge' {queue = expand_queue_name_shortcut(Q, State)}; +expand_shortcuts(#'queue.bind' {queue = Q, routing_key = K} = M, State) -> + M#'queue.bind' {queue = expand_queue_name_shortcut(Q, State), + routing_key = expand_routing_key_shortcut(Q, K, State)}; +expand_shortcuts(#'queue.unbind' {queue = Q, routing_key = K} = M, State) -> + M#'queue.bind' {queue = expand_queue_name_shortcut(Q, State), + routing_key = expand_routing_key_shortcut(Q, K, State)}; expand_shortcuts(M, _State) -> M. |