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 | 31d8836db7122d72f4be162246f5c20ba111669c (patch) | |
| tree | 5cafc31219c5be682191a5f499224bb6222697f7 /src | |
| parent | 8129668ce72e3e7633eef287c947d7f7d719074a (diff) | |
| download | rabbitmq-server-git-31d8836db7122d72f4be162246f5c20ba111669c.tar.gz | |
Removed check for durable queues on transient exchanges
Diffstat (limited to 'src')
| -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 815b9e35e3..e9161e8ad4 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) -> |
