Javadoc corrections

Author: Ian Craggs

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/IMqttClient.java

@@ -191,6 +191,7 @@ public interface IMqttClient { //extends IMqttAsyncClient {
 	 * published at a lower quality of service will be received at the published
 	 * QoS.  Messages published at a higher quality of service will be received using
 	 * the QoS specified on the subscribe.
+	 * @return a token
 	 * @throws MqttException if there was an error registering the subscription.
 	 */
   public IMqttToken subscribe(String topicFilter, int qos) throws MqttException;
@@ -288,6 +289,7 @@ public interface IMqttClient { //extends IMqttAsyncClient {
 	 * published at a lower quality of service will be received at the published
 	 * QoS.  Messages published at a higher quality of service will be received using
 	 * the QoS specified on the subscribe.
+	 * @return a token
 	 * @throws MqttException if there was an error registering the subscription.
 	 * @throws IllegalArgumentException if the two supplied arrays are not the same size.
 	 */
@@ -298,8 +300,10 @@ public interface IMqttClient { //extends IMqttAsyncClient {
 	 *
 	 * @see #subscribe(String[], int[])
 	 *
-	 * @param topicFilters the topic to subscribe to, which can include wildcards.
+	 * @param topicFilter the topic to subscribe to, which can include wildcards.
+	 * @param qos QoS
 	 * @param messageListener one callbacks to handle incoming messages
+	 * @return a token
 	 * @throws MqttException if there was an error registering the subscription.
 	 */
 public IMqttToken subscribe(String topicFilter, int qos, IMqttMessageListener messageListener) throws MqttException;
@@ -396,6 +400,7 @@ public interface IMqttClient { //extends IMqttAsyncClient {
 	 * QoS.  Messages published at a higher quality of service will be received using
 	 * the QoS specified on the subscribe.
 	 * @param messageListeners one or more callbacks to handle incoming messages
+	 * @return a token
 	 * @throws MqttException if there was an error registering the subscription.
 	 * @throws IllegalArgumentException if the two supplied arrays are not the same size.
 	 */

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttClient.java

@@ -150,7 +150,7 @@ public class MqttClient implements IMqttClient {
 	 * An instance of the default persistence mechanism
 	 * {@link MqttDefaultFilePersistence} is used by the client. To specify a
 	 * different persistence mechanism or to turn off persistence, use the
-	 * {@link #MqttLegacyBlockingClient(String, String, MqttClientPersistence)}
+	 * {@link #MqttClient(String, String, MqttClientPersistence)}
 	 * constructor.
 	 *
 	 * @param serverURI

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/MqttClientPersistence.java

@@ -23,7 +23,7 @@
 /**
  * Represents a persistent data store, used to store outbound and inbound messages while they
  * are in flight, enabling delivery to the QoS specified. You can specify an implementation
- * of this interface using {@link MqttClient#MqttLegacyBlockingClient(String, String, MqttClientPersistence)},
+ * of this interface using {@link MqttClient#MqttClient(String, String, MqttClientPersistence)},
  * which the {@link MqttClient} will use to persist QoS 1 and 2 messages.
  * <p>
  * If the methods defined throw the MqttPersistenceException then the state of the data persisted

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/alpha/MqttClientPersistence.java

@@ -22,8 +22,8 @@
 /**
  * Represents a persistent data store, used to store outbound and inbound messages while they
  * are in flight, enabling delivery to the QoS specified. You can specify an implementation
- * of this interface using {@link MqttLegacyBlockingClient#MqttLegacyBlockingClient(String, String)},
- * which the {@link MqttLegacyBlockingClient} will use to persist QoS 1 and 2 messages.
+ * of this interface using {@link MqttClient#MqttClient(String, String)},
+ * which the {@link MqttClient} will use to persist QoS 1 and 2 messages.
  * <p>
  * If the methods defined throw the MqttPersistenceException then the state of the data persisted
  * should remain as prior to the method being called. For example, if {@link #put(String, MqttPersistable)}

org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/ClientComms.java

@@ -91,7 +91,7 @@ public class ClientComms {
 	 * network calls.
 	 *
 	 * @param client
-	 *            The {@link IMqttAsyncClient}
+	 *            The {@link MqttClientInterface}
 	 * @param persistence
 	 *            the {@link MqttClientPersistence} layer.
 	 * @param pingSender