This commit is contained in:
Matthias Radestock 2012-07-31 12:14:18 +01:00
parent 3ad5db6112
commit 9a86b9910c
1 changed files with 1 additions and 2 deletions

View File

@ -450,8 +450,7 @@ ensure_upstream_bindings(State = #state{upstream = Upstream,
channel = Ch,
downstream_exchange = DownXName,
queue = Q}, Bindings) ->
#upstream{exchange = X,
params = Params} = Upstream,
#upstream{exchange = X, params = Params} = Upstream,
OldSuffix = rabbit_federation_db:get_active_suffix(
DownXName, Upstream, <<"A">>),
Suffix = case OldSuffix of