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
commitacc77d592b4b13c25a8d147f5889d7703c3fd401 (patch)
treedad7f5fbec4612c2d8d9e165d181a7487a27faf3
parent6db65737ad2ad3d67d50a1b5adc0cfa28b999029 (diff)
downloadrabbitmq-server-acc77d592b4b13c25a8d147f5889d7703c3fd401.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 9091d385..078bacb6 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}) ->