sectionsOccupied.put(sectionId, status);
}
return status == OCCUPIED;
}
@Override
<BUG>public void messageArrived(String topic, MqttMessage message) {
</BUG>
try {
<BUG>if (!sender.getSubscribedTopic().equals(topic)) {
return;
}</BUG>
OccupancyPayload payload = getOccupancyPayloadFromMessage(message);

sectionsOccupied.put(sectionId, status);
}
return status == OCCUPIED;
}
@Override
public void filteredMessageArrived(MqttMessage message) {
try {
OccupancyPayload payload = getOccupancyPayloadFromMessage(message);
