Fixing usage of DataOutputStream

Signed-off-by: Wajihulhassan <wajih.lums@gmail.com>

Author: emopers

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/wire/MqttSubscribe.java

@@ -128,6 +128,7 @@ public byte[] getPayload() throws MqttException {
 				encodeUTF8(dos,names[i]);
 				dos.writeByte(qos[i]);
 			}
+			dos.flush();
 			return baos.toByteArray();
 		} catch (IOException ex) {
 			throw new MqttException(ex);

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/wire/MqttUnsubscribe.java

@@ -99,12 +99,17 @@ protected byte[] getVariableHeader() throws MqttException {
 	}
 
 	public byte[] getPayload() throws MqttException {
-		ByteArrayOutputStream baos = new ByteArrayOutputStream();
-		DataOutputStream dos = new DataOutputStream(baos);
-		for (int i=0; i<names.length; i++) {
-			encodeUTF8(dos, names[i]);
+		try {
+			ByteArrayOutputStream baos = new ByteArrayOutputStream();
+			DataOutputStream dos = new DataOutputStream(baos);
+			for (int i=0; i<names.length; i++) {
+				encodeUTF8(dos, names[i]);
+			}
+			dos.flush();
+			return baos.toByteArray();
+		} catch (IOException ex) {
+			throw new MqttException(ex);
 		}
-		return baos.toByteArray();
 	}
 
 	public boolean isRetryable() {