public boolean addConsumer(MqttMessageSubscriber subscriber) throws MqttException {
String topic = subscriber.getTopic();
// Prepare topic for regex pattern matching taking place in messageArrived.
topic = StringUtils.replace(StringUtils.replace(topic, "+", "[^/]"), "#", "."); <<<------
synchronized (consumers) {
List subscriberList = consumers.get(topic);
if (subscriberList == null) {
subscriberList = new ArrayList<>();
}
subscriberList.add(subscriber);
consumers.put(topic, subscriberList);
}
if (isConnected()) {
try {
client.subscribe(topic, qos);
} catch (org.eclipse.paho.client.mqttv3.MqttException e) {
throw new MqttException(e);
}
}
return true;
}