iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[refs#BAEL-1992] Minor refactoring

This commit is contained in:
Philippe 2018-07-28 13:37:39 -03:00
parent bdbba67eb3
commit a1d1d6b16f
2 changed files with 27 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mqtt/README.md Normal file
View File

@ -0,0 +1,4 @@
### Relevant Articles:
================================
- [MQTT Client in Java](http://www.baeldung.com/mqtt-client)

45
mqtt/src/test/java/com/baeldung/mqtt/EngineTemperatureSensorLiveTest.java
View File

@ -24,12 +24,11 @@ public class EngineTemperatureSensorLiveTest {
@Test @Test
public void whenSendSingleMessage_thenSuccess() throws Exception { public void whenSendSingleMessage_thenSuccess() throws Exception {
String senderId = UUID.randomUUID().toString(); String publisherId = UUID.randomUUID().toString();
MqttClient sender = new MqttClient("tcp://iot.eclipse.org:1883",senderId); MqttClient publisher = new MqttClient("tcp://iot.eclipse.org:1883",publisherId);
String receiverId = UUID.randomUUID().toString();
MqttClient receiver = new MqttClient("tcp://iot.eclipse.org:1883",receiverId);
String subscriberId = UUID.randomUUID().toString();
MqttClient subscriber = new MqttClient("tcp://iot.eclipse.org:1883",subscriberId);
MqttConnectOptions options = new MqttConnectOptions(); MqttConnectOptions options = new MqttConnectOptions();
options.setAutomaticReconnect(true); options.setAutomaticReconnect(true);
@ -37,33 +36,34 @@ public class EngineTemperatureSensorLiveTest {
options.setConnectionTimeout(10); options.setConnectionTimeout(10);
receiver.connect(options); subscriber.connect(options);
sender.connect(options); publisher.connect(options);
CountDownLatch receivedSignal = new CountDownLatch(1); CountDownLatch receivedSignal = new CountDownLatch(1);
receiver.subscribe(EngineTemperatureSensor.TOPIC, (topic, msg) -> { subscriber.subscribe(EngineTemperatureSensor.TOPIC, (topic, msg) -> {
log.info("[I41] Message received: topic={}, payload={}", topic, new String(msg.getPayload())); byte[] payload = msg.getPayload();
log.info("[I46] Message received: topic={}, payload={}", topic, new String(payload));
receivedSignal.countDown(); receivedSignal.countDown();
}); });
Callable<Void> target = new EngineTemperatureSensor(sender); Callable<Void> target = new EngineTemperatureSensor(publisher);
target.call(); target.call();
receivedSignal.await(1, TimeUnit.MINUTES); receivedSignal.await(1, TimeUnit.MINUTES);
log.info("[I51] Success !"); log.info("[I56] Success !");
} }
@Test @Test
public void whenSendMultipleMessages_thenSuccess() throws Exception { public void whenSendMultipleMessages_thenSuccess() throws Exception {
String senderId = UUID.randomUUID().toString(); String publisherId = UUID.randomUUID().toString();
MqttClient sender = new MqttClient("tcp://iot.eclipse.org:1883",senderId); MqttClient publisher = new MqttClient("tcp://iot.eclipse.org:1883",publisherId);
String receiverId = UUID.randomUUID().toString(); String subscriberId = UUID.randomUUID().toString();
MqttClient receiver = new MqttClient("tcp://iot.eclipse.org:1883",receiverId); MqttClient subscriber = new MqttClient("tcp://iot.eclipse.org:1883",subscriberId);
MqttConnectOptions options = new MqttConnectOptions(); MqttConnectOptions options = new MqttConnectOptions();
@ -72,18 +72,19 @@ public class EngineTemperatureSensorLiveTest {
options.setConnectionTimeout(10); options.setConnectionTimeout(10);
sender.connect(options); publisher.connect(options);
receiver.connect(options); subscriber.connect(options);
CountDownLatch receivedSignal = new CountDownLatch(10); CountDownLatch receivedSignal = new CountDownLatch(10);
receiver.subscribe(EngineTemperatureSensor.TOPIC, (topic, msg) -> { subscriber.subscribe(EngineTemperatureSensor.TOPIC, (topic, msg) -> {
log.info("[I41] Message received: topic={}, payload={}", topic, new String(msg.getPayload())); byte[] payload = msg.getPayload();
log.info("[I82] Message received: topic={}, payload={}", topic, new String(payload));
receivedSignal.countDown(); receivedSignal.countDown();
}); });
Callable<Void> target = new EngineTemperatureSensor(sender); Callable<Void> target = new EngineTemperatureSensor(publisher);
ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
executor.scheduleAtFixedRate(() -> { executor.scheduleAtFixedRate(() -> {
@ -96,12 +97,12 @@ public class EngineTemperatureSensorLiveTest {
}, 1, 1, TimeUnit.SECONDS); }, 1, 1, TimeUnit.SECONDS);
receivedSignal.await(1, TimeUnit.DAYS); receivedSignal.await(1, TimeUnit.MINUTES);
executor.shutdown(); executor.shutdown();
assertTrue(receivedSignal.getCount() == 0 , "Countdown should be zero"); assertTrue(receivedSignal.getCount() == 0 , "Countdown should be zero");
log.info("[I51] Success !"); log.info("[I105] Success !");
} }