diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-05-26 20:10:38 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-05-26 20:10:38 +0100 |
| commit | a1d9c6d1faf7de49ab9f6d3681eef89d667cf742 (patch) | |
| tree | 4ab2ce0989af11f548d135264d49d2809b0e460d /src | |
| parent | b9298ea015696b410ec88413eb00b45d98464f5e (diff) | |
| download | rabbitmq-server-git-a1d9c6d1faf7de49ab9f6d3681eef89d667cf742.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 79cae8e053..0bc7fa09ba 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -855,8 +855,8 @@ handle_method(#'channel.flow'{active = false}, _, end; handle_method(#'channel.flow_ok'{active = Active}, _, - State = #ch{flow = F = #flow{server = Active, client = Flow, - pending = {_Ref, TRef}}}) + State = #ch{flow = #flow{server = Active, client = Flow, + pending = {_Ref, TRef}} = F}) when Flow =:= not Active -> {ok, cancel} = timer:cancel(TRef), {noreply, State#ch{flow = F#flow{client = Active, pending = none}}}; |