Skip to content

Commit

Permalink
NO-JIRA fix compilation issues in MQTT skeleton test
Browse files Browse the repository at this point in the history
  • Loading branch information
jbertram committed Dec 5, 2023
1 parent afe0e88 commit 5f2403a
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
import javax.jms.JMSConsumer;
import javax.jms.JMSContext;
import javax.jms.Message;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
Expand Down Expand Up @@ -68,8 +69,8 @@ public void testSimpleSendReceive() throws Exception {
subscriber.connect();
subscriber.setCallback(new DefaultMqttCallback() {
@Override
public void messageArrived(String topic, MqttMessage message) throws Exception {
log.info("Message received from {}", topic);
public void messageArrived(String topic, MqttMessage message) {
System.out.println("Message received from " + topic + ": " + message);
latch.countDown();
}
});
Expand Down

0 comments on commit 5f2403a

Please sign in to comment.