diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-07-02 13:22:49 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-07-02 13:22:49 +0100 |
| commit | 97e6379b573ac80e25d17587d15474214be78096 (patch) | |
| tree | 02e3cd768b3b5c941f859a4056eadb95199f13c5 /src | |
| parent | 6c8ddd2849d7273b886325f1ff24ccad388d4e04 (diff) | |
| download | rabbitmq-server-git-97e6379b573ac80e25d17587d15474214be78096.tar.gz | |
Remove an instance of hard-coding.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index d17d287c4f..495b0141aa 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -805,7 +805,7 @@ send_exception(State = #v1{connection = #connection{protocol = Protocol}}, map_exception(Channel, Reason, Protocol) -> {SuggestedClose, ReplyCode, ReplyText, FailedMethod} = - lookup_amqp_exception(Reason), + lookup_amqp_exception(Reason, Protocol), ShouldClose = SuggestedClose or (Channel == 0), {ClassId, MethodId} = case FailedMethod of {_, _} -> FailedMethod; @@ -827,12 +827,12 @@ map_exception(Channel, Reason, Protocol) -> lookup_amqp_exception(#amqp_error{name = Name, explanation = Expl, - method = Method}) -> - {ShouldClose, Code, Text} = - rabbit_framing_amqp_0_9_1:lookup_amqp_exception(Name), + method = Method}, + Protocol) -> + {ShouldClose, Code, Text} = Protocol:lookup_amqp_exception(Name), ExplBin = amqp_exception_explanation(Text, Expl), {ShouldClose, Code, ExplBin, Method}; -lookup_amqp_exception(Other) -> +lookup_amqp_exception(Other, _Protocol) -> rabbit_log:warning("Non-AMQP exit reason '~p'~n", [Other]), {ShouldClose, Code, Text} = rabbit_framing_0_9_1:lookup_amqp_exception(internal_error), |