in src/main/java/com/awslabs/iot/client/helpers/iot/BasicWebsocketsHelper.java [24:41]
public MqttCallback buildMessageCallback(Function<String, MqttMessage> messageArrivedHandler) {
return new MqttCallback() {
@Override
public void connectionLost(Throwable cause) {
}
@Override
public void messageArrived(String topic, MqttMessage message) {
messageArrivedHandler.handleMessage(topic, message);
}
@Override
public void deliveryComplete(IMqttDeliveryToken token) {
}
};
}