Searched refs:Mqtt5ClientOptions (Results 1 – 9 of 9) sorted by relevance
49 private Mqtt5ClientOptions clientOptions;58 public Mqtt5Client(Mqtt5ClientOptions options) throws CrtRuntimeException { in Mqtt5Client()231 public Mqtt5ClientOptions getClientOptions() in getClientOptions()267 Mqtt5ClientOptions options, in mqtt5ClientNew()
25 public class Mqtt5ClientOptions { class270 public Mqtt5ClientOptions(Mqtt5ClientOptionsBuilder builder) { in Mqtt5ClientOptions() method in Mqtt5ClientOptions870 public Mqtt5ClientOptions build() in build()872 return new Mqtt5ClientOptions(this); in build()
84 static final class SampleLifecycleEvents implements Mqtt5ClientOptions.LifecycleEvents {117 static final class SamplePublishEvents implements Mqtt5ClientOptions.PublishEvents {149 …Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder optionsBuilder = new Mqtt5ClientOptions.Mqtt5ClientOp… in main()
8 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.PublishEvents;94 static final class LifecycleEvents_Futured implements Mqtt5ClientOptions.LifecycleEvents {
14 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.LifecycleEvents;15 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder;
32 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.ClientOfflineQueueBehavior;33 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.ClientSessionBehavior;34 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.ExtendedValidationAndFlowControlOptions;35 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder;36 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.PublishEvents;200 … .withLifecycleEvents(new software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.LifecycleEvents() { in TestCreationFull()
30 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.ClientOfflineQueueBehavior;31 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.ClientSessionBehavior;32 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.ExtendedValidationAndFlowControlOptions;33 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.LifecycleEvents;34 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder;35 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.PublishEvents;1123 … static final class LifecycleEvents_DoubleClientID implements Mqtt5ClientOptions.LifecycleEvents {
18 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions;61 private static MqttConnectionConfig s_toMqtt3ConnectionConfig(Mqtt5ClientOptions mqtt5options) { in s_toMqtt3ConnectionConfig()74 … mqtt5options.getSessionBehavior().compareTo(Mqtt5ClientOptions.ClientSessionBehavior.CLEAN) <= 0); in s_toMqtt3ConnectionConfig()
31 import software.amazon.awssdk.crt.mqtt5.Mqtt5ClientOptions.Mqtt5ClientOptionsBuilder;242 static final class CanaryLifecycleEvents implements Mqtt5ClientOptions.LifecycleEvents {290 static final class CanaryPublishEvents implements Mqtt5ClientOptions.PublishEvents {320 clientOptionsBuilder.withSessionBehavior(Mqtt5ClientOptions.ClientSessionBehavior.CLEAN); in setupClients()