@Override
<BUG>public void messageArrived(String topic, MqttMessage message) {
</BUG>
try {
<BUG>if (!sender.getSubscribedTopic().equals(topic)) {
return;
}</BUG>
Payload payload = getPayloadFromMessage(message);
Command command = payload.getCommand();
switch (command) {

@Override
public void filteredMessageArrived(MqttMessage message) {
try {
Payload payload = getPayloadFromMessage(message);
Command command = payload.getCommand();
switch (command) {
