diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2011-03-23 14:11:09 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2011-03-23 14:11:09 +0000 |
| commit | fe150f5c5607dbda654074553000af2310d0a7e2 (patch) | |
| tree | 848f345dfbcea99eee057231bdc410030d6cb05c /src/rabbit_exchange_type_topic.erl | |
| parent | 05eb5fa6fff022148051b28c16744b82be982589 (diff) | |
| download | rabbitmq-server-fe150f5c5607dbda654074553000af2310d0a7e2.tar.gz | |
Do an impersonation of the serialisation thing for create / delete. Since the counter resets after delete this doesn't solve the problem but it makes the API cleaner and maybe future-proof.
Diffstat (limited to 'src/rabbit_exchange_type_topic.erl')
| -rw-r--r-- | src/rabbit_exchange_type_topic.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_exchange_type_topic.erl b/src/rabbit_exchange_type_topic.erl index 2f77b838..e3fd9283 100644 --- a/src/rabbit_exchange_type_topic.erl +++ b/src/rabbit_exchange_type_topic.erl @@ -56,11 +56,11 @@ recover(_Exchange, Bs) -> lists:foreach(fun (B) -> internal_add_binding(B) end, Bs) end). -delete(true, #exchange{name = X}, _Bs) -> +delete(transaction, #exchange{name = X}, _Bs) -> trie_remove_all_edges(X), trie_remove_all_bindings(X), ok; -delete(false, _Exchange, _Bs) -> +delete(none, _Exchange, _Bs) -> ok. add_binding(transaction, _Exchange, Binding) -> |