diff options
| author | Ben Hood <0x6e6562@gmail.com> | 2009-06-08 16:03:56 +0100 |
|---|---|---|
| committer | Ben Hood <0x6e6562@gmail.com> | 2009-06-08 16:03:56 +0100 |
| commit | 97f1ae552a09108d521f0f4ab50e8942bab34167 (patch) | |
| tree | 5cafc31219c5be682191a5f499224bb6222697f7 | |
| parent | a161bc1906c4c90d929cae35cd3d98db5fd648ab (diff) | |
| download | rabbitmq-server-97f1ae552a09108d521f0f4ab50e8942bab34167.tar.gz | |
Removed check for durable queues on transient exchanges
| -rw-r--r-- | src/rabbit_exchange.erl | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/rabbit_exchange.erl b/src/rabbit_exchange.erl index 815b9e35..e9161e8a 100644 --- a/src/rabbit_exchange.erl +++ b/src/rabbit_exchange.erl @@ -367,12 +367,8 @@ call_with_exchange_and_queue(Exchange, Queue, Fun) -> add_binding(ExchangeName, QueueName, RoutingKey, Arguments) -> binding_action( ExchangeName, QueueName, RoutingKey, Arguments, - fun (X, Q, B) -> - if Q#amqqueue.durable and not(X#exchange.durable) -> - {error, durability_settings_incompatible}; - true -> ok = sync_binding(B, Q#amqqueue.durable, - fun mnesia:write/3) - end + fun (_X, Q, B) -> + ok = sync_binding(B, Q#amqqueue.durable, fun mnesia:write/3) end). delete_binding(ExchangeName, QueueName, RoutingKey, Arguments) -> |