Skip to content

Commit f908f23

Browse files
committed
Fixed example in readme
1 parent b101bdd commit f908f23

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

README.md

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,12 @@ public class MQTTClientDemo {
3535
SimpleMQTTClient sc = new SimpleMQTTClient("localhost", "test-bot");
3636

3737
// Subscribe to a channel and register a callback for it
38-
sc.subscribe("myChannel", message -> System.out.println(message));
38+
sc.subscribe("myChannel", new MessageListener() {
39+
@Override
40+
public void processMessage(String message) {
41+
System.out.println(message);
42+
}
43+
});
3944

4045
// Do something...
4146

0 commit comments

Comments
 (0)