File tree Expand file tree Collapse file tree 4 files changed +9
-14
lines changed
src/main/java/info/unterrainer/commons/mqttclient Expand file tree Collapse file tree 4 files changed +9
-14
lines changed Original file line number Diff line number Diff line change @@ -30,3 +30,5 @@ hs_err_pid*
30
30
.settings /
31
31
32
32
src /main /java /info /unterrainer /server /mqttclient /Information.java
33
+
34
+ src /main /java /info /unterrainer /commons /mqttclient /Information.java
Original file line number Diff line number Diff line change 9
9
</parent >
10
10
11
11
<properties >
12
- <mainclass >info.unterrainer.server .mqttclient.MqttClient</mainclass >
13
- <name >Elite-Server-DTOs </name >
14
- <package-path >info/unterrainer/server /mqttclient</package-path >
15
- <packg-string >info.unterrainer.server .mqttclient</packg-string >
12
+ <mainclass >info.unterrainer.commons .mqttclient.MqttClient</mainclass >
13
+ <name >MQTT-Client </name >
14
+ <package-path >info/unterrainer/commons /mqttclient</package-path >
15
+ <packg-string >info.unterrainer.commons .mqttclient</packg-string >
16
16
</properties >
17
17
18
18
<modelVersion >4.0.0</modelVersion >
19
19
<artifactId >mqtt-client</artifactId >
20
- <version >0.1.0 </version >
20
+ <version >0.1.1 </version >
21
21
<name >MqttClient</name >
22
22
<packaging >jar</packaging >
23
23
24
24
<dependencies >
25
25
<dependency >
26
26
<groupId >info.unterrainer.commons</groupId >
27
27
<artifactId >jre-utils</artifactId >
28
- <version >0.3.0 </version >
28
+ <version >0.3.1 </version >
29
29
</dependency >
30
30
<dependency >
31
31
<groupId >info.unterrainer.commons</groupId >
Load Diff This file was deleted.
Original file line number Diff line number Diff line change @@ -16,7 +16,7 @@ public class MqttSubscriptionManager<T extends MqttSubscription> {
16
16
17
17
public void updateDifferentialSubscriptionsOnClient () {
18
18
client .connect ();
19
- SetIntersection intersection = SetIntersection .of (getCurrentMap ().keySet (), getOldMap ().keySet ());
19
+ SetIntersection intersection = SetIntersection .of (getOldMap ().keySet (), getCurrentMap ().keySet ());
20
20
for (String topic : intersection .getDelete ())
21
21
client .unsubscribe (topic );
22
22
Map <String , T > map = getCurrentMap ();
You can’t perform that action at this time.
0 commit comments