summaryrefslogtreecommitdiff
path: root/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl
diff options
context:
space:
mode:
authorMarek Wiewiorski <mwiewiorski@opera.com>2015-06-22 17:54:16 +0200
committerMarek Wiewiorski <mwiewiorski@opera.com>2015-06-22 17:54:16 +0200
commitdb7053e4eb4b1a4d453bda8c0bc3c27748f1466e (patch)
treec1fc45a1a3fc927c69ac8d34ac01376dda958a01 /deps/rabbitmq_federation/src/rabbit_federation_upstream.erl
parentfd58a6142c8ef3a307d1c8d40895034efd1529d2 (diff)
downloadrabbitmq-server-git-db7053e4eb4b1a4d453bda8c0bc3c27748f1466e.tar.gz
Make no-wait flag on exchange.bind and exchange.unbind configurable
Diffstat (limited to 'deps/rabbitmq_federation/src/rabbit_federation_upstream.erl')
-rw-r--r--deps/rabbitmq_federation/src/rabbit_federation_upstream.erl3
1 files changed, 2 insertions, 1 deletions
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl b/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl
index 168fce0fde..035220c555 100644
--- a/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl
+++ b/deps/rabbitmq_federation/src/rabbit_federation_upstream.erl
@@ -131,7 +131,8 @@ from_upstream_or_set(US, Name, U, XorQ) ->
binary_to_list(
bget('ack-mode', US, U, <<"on-confirm">>))),
ha_policy = bget('ha-policy', US, U, none),
- name = Name}.
+ name = Name,
+ bind_nowait = bget('bind-nowait', US, U, false)}.
%%----------------------------------------------------------------------------