summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorVlad Alexandru Ionescu <vlad@rabbitmq.com>2010-09-30 15:20:58 +0100
committerVlad Alexandru Ionescu <vlad@rabbitmq.com>2010-09-30 15:20:58 +0100
commita1f714184c743d13444d25b708c37eadfccaa0ee (patch)
treedad7f5fbec4612c2d8d9e165d181a7487a27faf3
parentb044ddc344e53941275250407f2217dd839c71b1 (diff)
downloadrabbitmq-server-git-a1f714184c743d13444d25b708c37eadfccaa0ee.tar.gz
minor
-rw-r--r--src/rabbit_exchange_type_topic.erl8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_exchange_type_topic.erl b/src/rabbit_exchange_type_topic.erl
index 9091d385d1..078bacb606 100644
--- a/src/rabbit_exchange_type_topic.erl
+++ b/src/rabbit_exchange_type_topic.erl
@@ -222,20 +222,20 @@ trie_binding_op(X, Node, Q, Op) ->
trie_has_any_children(X, Node) ->
MatchHead = #topic_trie_edge{trie_edge = #trie_edge{exchange_name = X,
node_id = Node,
- word = '$1'},
+ _='_'},
_='_'},
Select = mnesia:select(rabbit_topic_trie_edge,
- [{MatchHead, [], ['$1']}], 1, read),
+ [{MatchHead, [], ['$_']}], 1, read),
select_while_no_result(Select) /= '$end_of_table'.
trie_has_any_bindings(X, Node) ->
MatchHead = #topic_trie_binding{
trie_binding = #trie_binding{exchange_name = X,
node_id = Node,
- queue_name = '$1'},
+ _='_'},
_='_'},
Select = mnesia:select(rabbit_topic_trie_binding,
- [{MatchHead, [], ['$1']}], 1, read),
+ [{MatchHead, [], ['$_']}], 1, read),
select_while_no_result(Select) /= '$end_of_table'.
select_while_no_result({[], Cont}) ->