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 | ad8341984ed89f8d952481f66dcd95f3077b2b1b (patch) | |
| tree | 0f2aaf3c1be45c5d9109c3d23fd2122038fb514c /src/rabbit_channel.erl | |
| parent | 9d37995bb673d11ba28a39acef5d9448b876c3ce (diff) | |
| download | rabbitmq-server-ad8341984ed89f8d952481f66dcd95f3077b2b1b.tar.gz | |
Verticality
Diffstat (limited to 'src/rabbit_channel.erl')
| -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 78826554..bd9d7632 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. |