diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-08-02 10:24:40 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-08-02 10:24:40 +0100 |
| commit | e89b9c806bcf671bd2879c76927cf9014e14df2e (patch) | |
| tree | 1c949423437b4c02af5491aa1cda73838301b722 | |
| parent | 9689eaa9cec4a31fed2c2f1457f18c236511c438 (diff) | |
| download | rabbitmq-server-e89b9c806bcf671bd2879c76927cf9014e14df2e.tar.gz | |
Work around broken py-amqplib handshaking
| -rw-r--r-- | src/rabbit_reader.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 9603faf5..f687f814 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -569,6 +569,10 @@ handle_input(handshake, <<"AMQP", 1, 1, 0, 9>>, State) -> handle_input(handshake, <<"AMQP", 1, 1, 8, 0>>, State) -> start_connection({8, 0, 0}, rabbit_framing_amqp_0_8, State); +%% py-amqplib has always sent this broken version. It wants 0-8. +handle_input(handshake, <<"AMQP", 1, 1, 9, 1>>, State) -> + start_connection({8, 0, 0}, rabbit_framing_amqp_0_8, State); + handle_input(handshake, <<"AMQP", A, B, C, D>>, #v1{sock = Sock}) -> refuse_connection(Sock, {bad_version, A, B, C, D}); |