public MqttCallback buildMessageCallback()

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) {

            }
        };
    }