Package software.amazon.awssdk.iot
Class V2ClientStreamOptions<T>
- java.lang.Object
-
- software.amazon.awssdk.iot.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
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classV2ClientStreamOptions.V2ClientStreamOptionsBuilder<T>Builder type for V2ClientStreamOptions instances
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> V2ClientStreamOptions.V2ClientStreamOptionsBuilder<T>builder()Creates a new builder object for V2ClientStreamOptions instancesConsumer<V2DeserializationFailureEvent>deserializationFailureHandler()Consumer<T>streamEventHandler()Consumer<software.amazon.awssdk.crt.iot.SubscriptionStatusEvent>subscriptionEventHandler()
-
-
-
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
-
-