Fixing Maven versions in pom for v5 clients

Signed-off-by: James Sutton <james.sutton@uk.ibm.com>

Author: jpwsutton

org.eclipse.paho.mqttv5.client/pom.xml

@@ -46,7 +46,11 @@
 		<dependency>
 			<groupId>org.eclipse.paho</groupId>
 			<artifactId>org.eclipse.paho.mqttv5.common</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
+			<version>1.2.1-SNAPSHOT</version>
+		</dependency>
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
 		</dependency>
 	</dependencies>
 

org.eclipse.paho.mqttv5.testclient/pom.xml

@@ -52,12 +52,12 @@
     <dependency>
     	<groupId>org.eclipse.paho</groupId>
     	<artifactId>org.eclipse.paho.mqttv5.client</artifactId>
-    	<version>0.0.1-SNAPSHOT</version>
+    	<version>1.2.1-SNAPSHOT</version>
     </dependency>
     <dependency>
     	<groupId>org.eclipse.paho</groupId>
     	<artifactId>org.eclipse.paho.mqttv5.common</artifactId>
-    	<version>0.0.1-SNAPSHOT</version>
+    	<version>1.2.1-SNAPSHOT</version>
     </dependency>
   </dependencies>
 

org.eclipse.paho.mqttv5.testclient/src/main/java/org/eclipse/paho/mqttv5/testclient/V5Client.java

@@ -37,7 +37,7 @@ public V5Client() throws InterruptedException {
 			MqttConnectionOptionsBuilder conOptsBuilder = new MqttConnectionOptionsBuilder();
 			MqttConnectionOptions conOpts = conOptsBuilder.serverURI(broker).cleanSession(true)
 					.sessionExpiryInterval(120).automaticReconnect(true)
-					.will(topic, new MqttMessage(willContent.getBytes(), qos, false)).topicAliasMaximum(1000).build();
+					.will(topic, new MqttMessage(willContent.getBytes(), qos, false, null)).topicAliasMaximum(1000).build();
 			asyncClient.setCallback(this);
 
 
@@ -83,7 +83,7 @@ public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
 					message = "FINISH";
 					running = false;
 				}
-				asyncClient.publish(topic, new MqttMessage(message.getBytes(), 2, false));
+				asyncClient.publish(topic, new MqttMessage(message.getBytes(), 2, false, null));
 				x++;
 
 			}
@@ -139,6 +139,16 @@ public void mqttErrorOccured(MqttException exception) {
 		// TODO Auto-generated method stub
 
 	}
+
+	@Override
+	public void connectComplete(boolean reconnect, String serverURI) {
+		
+	}
+
+	@Override
+	public void authPacketArrived(int reasonCode, MqttProperties properties) {
+		
+	}
 
 
 }