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 class
V2ClientStreamOptions.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
-
-