School/WasteInformationServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

8.11.2019 MQTT finished

Browse Source
This commit is contained in:
Gregor_Dutzler 2019-11-08 15:07:29 +01:00
parent a4563def38
commit 797d29281b
3 changed files with 0 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
JavaSample-tcp19216865151883/.lck Normal file
View File

5
src/com/wasteinformationserver/mqtt/mqtt.java
View File

@ -8,13 +8,10 @@ import java.awt.event.ActionListener;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;
import java.text.DateFormat; import java.text.DateFormat;
import java.util.ArrayList;
import java.util.GregorianCalendar; import java.util.GregorianCalendar;
public class mqtt { public class mqtt {
ArrayList<String> mylist = new ArrayList<>();
int index = 0;
public mqtt() { public mqtt() {
@ -74,7 +71,6 @@ public class mqtt {
if (temp != null) { if (temp != null) {
transmitmessageAbfallart(temp); transmitmessageAbfallart(temp);
notifymessage();
} else { } else {
Log.debug("NO Connection"); Log.debug("NO Connection");
} }
@ -84,7 +80,6 @@ public class mqtt {
e.printStackTrace(); e.printStackTrace();
} }
} }

5
src/com/wasteinformationserver/mqtt/mqtttransmitter.java
View File

@ -10,8 +10,6 @@ import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class mqtttransmitter { public class mqtttransmitter {
private String messagedatabase;
public mqtttransmitter() { public mqtttransmitter() {
} }
@ -23,8 +21,6 @@ public class mqtttransmitter {
String clientId = "JavaSample"; String clientId = "JavaSample";
MemoryPersistence persistence = new MemoryPersistence(); MemoryPersistence persistence = new MemoryPersistence();
System.out.println("HI");
try { try {
MqttClient sampleClient = new MqttClient(broker, clientId, persistence); MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
MqttConnectOptions connOpts = new MqttConnectOptions(); MqttConnectOptions connOpts = new MqttConnectOptions();
@ -50,5 +46,4 @@ public class mqtttransmitter {
me.printStackTrace(); me.printStackTrace();
} }
} }
} }