Skip to content

Commit 815543a

Browse files
Ranjan-DasguptaRanjan-Dasgupta
authored andcommitted
Merge mqttv5 modules client and common
Signed-off-by: Ranjan-Dasgupta <Ranjan.Dasgupta@us.ibm.com>
1 parent 3e3b6c4 commit 815543a

85 files changed

Lines changed: 22 additions & 95 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

org.eclipse.paho.client.mqttv3/META-INF/MANIFEST.MF

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
Manifest-Version: 1.0
22
Bundle-ManifestVersion: 2
3-
Bundle-Name: %bundle.name
3+
Bundle-Name: org.eclipse.paho.client.mqttv3
44
Bundle-SymbolicName: org.eclipse.paho.client.mqttv3
55
Bundle-Version: 1.2.5.qualifier
66
Bundle-Localization: bundle

org.eclipse.paho.client.mqttv3/src/main/java-templates/org/eclipse/paho/client/mqttv3/internal/ClientComms.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,7 @@ public class ClientComms {
9393
* @param persistence the {@link MqttClientPersistence} layer.
9494
* @param pingSender the {@link MqttPingSender}
9595
* @param executorService the {@link ExecutorService}
96+
* @param highResolutionTimer the {@link HighResolutionTimer}
9697
* @throws MqttException if an exception occurs whilst communicating with the server
9798
*/
9899
public ClientComms(IMqttAsyncClient client, MqttClientPersistence persistence, MqttPingSender pingSender,

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsReceiver.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ public void run() {
168168
}
169169
else {
170170
// fix for bug 719
171-
if (!clientComms.isConnected()) {
171+
if (!clientComms.isConnected() && !clientComms.isConnecting()) {
172172
throw new IOException("Connection is lost.");
173173
}
174174
}

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,6 @@
2727
<version>3.8.1</version>
2828
<scope>test</scope>
2929
</dependency>
30-
<dependency>
31-
<groupId>org.eclipse.paho</groupId>
32-
<artifactId>org.eclipse.paho.mqttv5.common</artifactId>
33-
<version>1.2.5-SNAPSHOT</version>
34-
</dependency>
3530
<dependency>
3631
<groupId>org.eclipse.paho</groupId>
3732
<artifactId>org.eclipse.paho.mqttv5.client</artifactId>

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,6 @@
1414
<name>org.eclipse.paho.mqttv5.client</name>
1515

1616
<dependencies>
17-
<dependency>
18-
<groupId>org.eclipse.paho</groupId>
19-
<artifactId>org.eclipse.paho.mqttv5.common</artifactId>
20-
<version>1.2.5-SNAPSHOT</version>
21-
</dependency>
2217
<dependency>
2318
<groupId>junit</groupId>
2419
<artifactId>junit</artifactId>

org.eclipse.paho.mqttv5.common/src/main/java/org/eclipse/paho/mqttv5/common/ExceptionHelper.java renamed to org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/common/ExceptionHelper.java

File renamed without changes.

org.eclipse.paho.mqttv5.common/src/main/java/org/eclipse/paho/mqttv5/common/MqttException.java renamed to org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/common/MqttException.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,9 @@ public MqttException(int reasonCode) {
5757
* meant as a hint for the developer, as the
5858
* <code>MqttCallback.disconnected</code> callback is the intended disconnect
5959
* notification mechanism.
60+
*
61+
* @param reasonCode the reason code for the exception.
62+
* @param disconnect diconnect flag
6063
*/
6164
public MqttException(int reasonCode, MqttDisconnect disconnect) {
6265
super();

org.eclipse.paho.mqttv5.common/src/main/java/org/eclipse/paho/mqttv5/common/MqttMessage.java renamed to org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/common/MqttMessage.java

File renamed without changes.

org.eclipse.paho.mqttv5.common/src/main/java/org/eclipse/paho/mqttv5/common/MqttPersistable.java renamed to org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/common/MqttPersistable.java

File renamed without changes.

org.eclipse.paho.mqttv5.common/src/main/java/org/eclipse/paho/mqttv5/common/MqttPersistenceException.java renamed to org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/common/MqttPersistenceException.java

File renamed without changes.

0 commit comments

Comments
 (0)