diff --git a/JavaSample-tcp19216865151883/.lck b/JavaSample-tcp19216865151883/.lck new file mode 100644 index 0000000..e69de29 diff --git a/src/com/wasteinformationserver/mqtt/mqtt.java b/src/com/wasteinformationserver/mqtt/mqtt.java index d38ec27..6a94129 100644 --- a/src/com/wasteinformationserver/mqtt/mqtt.java +++ b/src/com/wasteinformationserver/mqtt/mqtt.java @@ -85,11 +85,11 @@ public class mqtt { String[] partstwo = date.split(" "); - boolean abholtag; + int abholtag; if (partstwo[0].contains(newDate)) { - abholtag = true; + abholtag = 1; } else { - abholtag = false; + abholtag = 0; } temp = tempabfallart + "," + abholtag; diff --git a/src/com/wasteinformationserver/mqtt/mqtttransmitter.java b/src/com/wasteinformationserver/mqtt/mqtttransmitter.java index df780fc..ed385ef 100644 --- a/src/com/wasteinformationserver/mqtt/mqtttransmitter.java +++ b/src/com/wasteinformationserver/mqtt/mqtttransmitter.java @@ -24,9 +24,9 @@ public class mqtttransmitter { String clientId = "JavaSample"; MemoryPersistence persistence = new MemoryPersistence(); + System.out.println("HI"); try { - MqttClient sampleClient = new MqttClient(broker, clientId, persistence); MqttConnectOptions connOpts = new MqttConnectOptions(); connOpts.setCleanSession(true); @@ -40,6 +40,7 @@ public class mqtttransmitter { Log.debug("Message published"); sampleClient.disconnect(); Log.debug("Disconnected"); + System.out.println("HI"); } catch (MqttException me) {