Class V2ClientStreamOptions<T>

  • Type Parameters:
    T - Type that the stream deserializes MQTT messages into

    public class V2ClientStreamOptions<T>
    extends Object
    Configuration options for streaming operations created from the V2 service clients
    • Method Detail

      • builder

        public static <T> V2ClientStreamOptions.V2ClientStreamOptionsBuilder<T> builder()
        Creates a new builder object for V2ClientStreamOptions instances
        Type Parameters:
        T - Type that the stream deserializes MQTT messages into
        Returns:
        a new builder object for V2ClientStreamOptions instances
      • streamEventHandler

        public Consumer<T> streamEventHandler()
        Returns:
        the callback the stream should invoke on a successfully deserialized message
      • subscriptionEventHandler

        public Consumer<software.amazon.awssdk.crt.iot.SubscriptionStatusEvent> subscriptionEventHandler()
        Returns:
        the callback the stream should invoke when a message fails to deserialize
      • deserializationFailureHandler

        public Consumer<V2DeserializationFailureEvent> deserializationFailureHandler()
        Returns:
        the callback the stream should invoke when something changes about the underlying subscription