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

Modifier and Type	Method	Description
static <T> V2ClientStreamOptions.V2ClientStreamOptionsBuilder<T>	builder()	Creates a new builder object for V2ClientStreamOptions instances
Consumer<V2DeserializationFailureEvent>	deserializationFailureHandler()
Consumer<T>	streamEventHandler()
Consumer<software.amazon.awssdk.crt.iot.SubscriptionStatusEvent>	subscriptionEventHandler()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

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