We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 718a9d3 commit 1244829Copy full SHA for 1244829
src/com/rabbitmq/client/impl/Frame.java
@@ -177,6 +177,13 @@ public static void protocolVersionMismatch(DataInputStream is) throws IOExceptio
177
int transportLow = is.readUnsignedByte();
178
int serverMajor = is.readUnsignedByte();
179
int serverMinor = is.readUnsignedByte();
180
+
181
+ // 0-8 gets these the wrong way round
182
+ if (serverMajor == 8 && serverMinor == 0) {
183
+ serverMajor = 0;
184
+ serverMinor = 8;
185
+ }
186
187
x = new MalformedFrameException("AMQP protocol version mismatch; we are version " + AMQP.PROTOCOL.MAJOR + "-" + AMQP.PROTOCOL.MINOR
188
+ ", server is " + serverMajor + "-" + serverMinor + " with transport " + transportHigh + "." + transportLow);
189
} catch (IOException ex) {
0 commit comments