Fixing the persistence to use during re-open instead of . Will be consistent with (#292)

satyadeepk · jpwsutton · commit 9b0c5e97562f · 2016-11-09T09:25:09.000Z
Signed-off-by: Satyadeep &lt;satyadeep.1991@gmail.com&gt;
diff --git a/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/ClientState.java b/org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/ClientState.java
@@ -569,7 +569,7 @@ public void persistBufferedMessage(MqttWireMessage message) {
 			} catch (MqttPersistenceException mpe){
 				//@TRACE 515=Could not Persist, attempting to Re-Open Persistence Store
 				log.fine(CLASS_NAME,methodName, "515");
-				persistence.open(this.clientComms.getClient().getClientId(), this.clientComms.getClient().getClientId());
+				persistence.open(this.clientComms.getClient().getClientId(), this.clientComms.getClient().getServerURI());
 				persistence.put(key, (MqttPublish) message);
 			}
 			//@TRACE 513=Persisted Buffered Message key={0}

Original file line number	Diff line number	Diff line change
`@@ -569,7 +569,7 @@ public void persistBufferedMessage(MqttWireMessage message) {`
`569`	`569`	`} catch (MqttPersistenceException mpe){`
`570`	`570`	`//@TRACE 515=Could not Persist, attempting to Re-Open Persistence Store`
`571`	`571`	`log.fine(CLASS_NAME,methodName, "515");`
`572`		`- persistence.open(this.clientComms.getClient().getClientId(), this.clientComms.getClient().getClientId());`
	`572`	`+ persistence.open(this.clientComms.getClient().getClientId(), this.clientComms.getClient().getServerURI());`
`573`	`573`	`persistence.put(key, (MqttPublish) message);`
`574`	`574`	`}`
`575`	`575`	`//@TRACE 513=Persisted Buffered Message key={0}`