Issue #540 - Allow Auth packet on read.

jpwsutton · jpwsutton · commit 9740268a4214 · 2018-05-11T16:08:44.000+01:00
Signed-off-by: James Sutton &lt;james.sutton@uk.ibm.com&gt;
diff --git a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/wire/MqttInputStream.java b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/wire/MqttInputStream.java
@@ -97,7 +97,7 @@ public MqttWireMessage readMqttWireMessage() throws IOException, MqttException {
 
 				byte type = (byte) ((first >>> 4) & 0x0F);
 				if ((type < MqttWireMessage.MESSAGE_TYPE_CONNECT) ||
-						(type > MqttWireMessage.MESSAGE_TYPE_DISCONNECT)) {
+						(type > MqttWireMessage.MESSAGE_TYPE_AUTH)) {
 					// Invalid MQTT message type...
 					throw ExceptionHelper.createMqttException(MqttClientException.REASON_CODE_INVALID_MESSAGE);
 				}

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,7 @@ public MqttWireMessage readMqttWireMessage() throws IOException, MqttException {`
`97`	`97`
`98`	`98`	`byte type = (byte) ((first >>> 4) & 0x0F);`
`99`	`99`	`if ((type < MqttWireMessage.MESSAGE_TYPE_CONNECT) \|\|`
`100`		`- (type > MqttWireMessage.MESSAGE_TYPE_DISCONNECT)) {`
	`100`	`+ (type > MqttWireMessage.MESSAGE_TYPE_AUTH)) {`
`101`	`101`	`// Invalid MQTT message type...`
`102`	`102`	`throw ExceptionHelper.createMqttException(MqttClientException.REASON_CODE_INVALID_MESSAGE);`
`103`	`103`	`}`