import org.eclipse.paho.client.mqttv3.MqttMessage;
public class TurnoutRequestSender implements MqttCallback {
private final MQTTPublisherSubscriber sender;</BUG>
private volatile boolean pollingEnabled = false;
<BUG>private final Map<Integer, TurnoutStatus> turnoutStatuses = new ConcurrentHashMap<>();
public TurnoutRequestSender(MQTTConfiguration config) {
config.setClientID(generateId(getClass().getSimpleName()));
this.sender = new MQTTPublisherSubscriber(config);
this.sender.subscribe(this);</BUG>
}

import org.eclipse.paho.client.mqttv3.MqttMessage;
public class TurnoutRequestSender extends RequestSender {
private volatile boolean pollingEnabled = false;
private final Map<Integer, TurnoutStatus> turnoutStatuses = new ConcurrentHashMap<>();
public TurnoutRequestSender(MQTTPublisherSubscriber mqtt) throws MqttException {
super("modes3/kvcontrol/turnout", mqtt);
}
