| /external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/ |
| D | Mqtt5ClientTest.java | 73 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in New_UC1()
127 …public void onAttemptingConnect(Mqtt5Client client, OnAttemptingConnectReturn onAttemptingConnectR… in New_UC2()
130 …public void onConnectionSuccess(Mqtt5Client client, OnConnectionSuccessReturn onConnectionSuccessR… in New_UC2()
133 …public void onConnectionFailure(Mqtt5Client client, OnConnectionFailureReturn onConnectionFailureR… in New_UC2()
136 … public void onDisconnection(Mqtt5Client client, OnDisconnectionReturn onDisconnectionReturn) {} in New_UC2()
139 public void onStopped(Mqtt5Client client, OnStoppedReturn onStoppedReturn) {} in New_UC2()
149 … public void onMessageReceived(Mqtt5Client client, PublishReturn publishReturn) {} in New_UC2()
162 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in New_UC2()
181 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in New_UC3()
234 …public void onAttemptingConnect(Mqtt5Client client, OnAttemptingConnectReturn onAttemptingConnectR… in New_UC4()
[all …]
|
| D | Mqtt5to3AdapterConnectionTest.java | 121 boolean Mqtt3Connect(Mqtt5Client client) throws Exception { in Mqtt3Connect()
147 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in TestCreationMinimal()
202 public void onAttemptingConnect(Mqtt5Client client, in TestCreationFull()
207 public void onConnectionSuccess(Mqtt5Client client, in TestCreationFull()
212 public void onConnectionFailure(Mqtt5Client client, in TestCreationFull()
217 public void onDisconnection(Mqtt5Client client, in TestCreationFull()
222 … public void onStopped(Mqtt5Client client, OnStoppedReturn onStoppedReturn) { in TestCreationFull()
233 … public void onMessageReceived(Mqtt5Client client, PublishReturn publishReturn) { in TestCreationFull()
247 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in TestCreationFull()
278 try (Mqtt5Client client = new Mqtt5Client(builder.build()); in TestDirectConnectThroughMqtt5()
[all …]
|
| D | Mqtt5ClientTestFixture.java | 108 …public void onAttemptingConnect(Mqtt5Client client, OnAttemptingConnectReturn onAttemptingConnectR… in onAttemptingConnect()
111 …public void onConnectionSuccess(Mqtt5Client client, OnConnectionSuccessReturn onConnectionSuccessR… in onConnectionSuccess()
120 …public void onConnectionFailure(Mqtt5Client client, OnConnectionFailureReturn onConnectionFailureR… in onConnectionFailure()
127 … public void onDisconnection(Mqtt5Client client, OnDisconnectionReturn onDisconnectionReturn) { in onDisconnection()
133 public void onStopped(Mqtt5Client client, OnStoppedReturn onStoppedReturn) { in onStopped()
143 public void onMessageReceived(Mqtt5Client client, PublishReturn result) { in onMessageReceived()
161 HashMap<Mqtt5Client, Integer> clientsReceived = new HashMap<Mqtt5Client, Integer>();
164 public void onMessageReceived(Mqtt5Client client, PublishReturn result) { in onMessageReceived()
|
| D | CustomKeyOpsTest.java | 13 import software.amazon.awssdk.crt.mqtt5.Mqtt5Client;
163 …public void onAttemptingConnect(Mqtt5Client client, software.amazon.awssdk.crt.mqtt5.OnAttemptingC… in onAttemptingConnect()
165 …public void onConnectionSuccess(Mqtt5Client client, software.amazon.awssdk.crt.mqtt5.OnConnectionS… in onConnectionSuccess()
169 …public void onConnectionFailure(Mqtt5Client client, software.amazon.awssdk.crt.mqtt5.OnConnectionF… in onConnectionFailure()
173 …public void onDisconnection(Mqtt5Client client, software.amazon.awssdk.crt.mqtt5.OnDisconnectionRe… in onDisconnection()
175 …public void onStopped(Mqtt5Client client, software.amazon.awssdk.crt.mqtt5.OnStoppedReturn onStopp… in onStopped()
198 try (Mqtt5Client client = new Mqtt5Client(builder.build())) { in testHappyPathMQTT5()
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt5/ |
| D | Mqtt5WebsocketHandshakeTransformArgs.java | 23 private Mqtt5Client mqttClient;
32 public Mqtt5WebsocketHandshakeTransformArgs(Mqtt5Client mqttClient, HttpRequest httpRequest, in Mqtt5WebsocketHandshakeTransformArgs()
45 public Mqtt5Client getMqttClient() { in getMqttClient()
|
| D | Mqtt5ClientOptions.java | 308 …public void onAttemptingConnect(Mqtt5Client client, OnAttemptingConnectReturn onAttemptingConnectR… in onAttemptingConnect()
316 …public void onConnectionSuccess(Mqtt5Client client, OnConnectionSuccessReturn onConnectionSuccessR… in onConnectionSuccess()
324 …public void onConnectionFailure(Mqtt5Client client, OnConnectionFailureReturn onConnectionFailureR… in onConnectionFailure()
332 … public void onDisconnection(Mqtt5Client client, OnDisconnectionReturn onDisconnectionReturn); in onDisconnection()
340 public void onStopped(Mqtt5Client client, OnStoppedReturn onStoppedReturn); in onStopped()
353 public void onMessageReceived(Mqtt5Client client, PublishReturn publishReturn); in onMessageReceived()
|
| D | Mqtt5Client.java | 34 public class Mqtt5Client extends CrtResource { class
58 public Mqtt5Client(Mqtt5ClientOptions options) throws CrtRuntimeException { in Mqtt5Client() method in Mqtt5Client
270 Mqtt5Client client in mqtt5ClientNew()
|
| /external/aws-crt-java/samples/mqtt5/src/main/java/com/example/mqtt5/ |
| D | Mqtt5Sample.java | 89 …public void onAttemptingConnect(Mqtt5Client client, OnAttemptingConnectReturn onAttemptingConnectR… in onAttemptingConnect()
94 …public void onConnectionSuccess(Mqtt5Client client, OnConnectionSuccessReturn onConnectionSuccessR… in onConnectionSuccess()
100 …public void onConnectionFailure(Mqtt5Client client, OnConnectionFailureReturn onConnectionFailureR… in onConnectionFailure()
106 … public void onDisconnection(Mqtt5Client client, OnDisconnectionReturn onDisconnectionReturn) { in onDisconnection()
111 public void onStopped(Mqtt5Client client, OnStoppedReturn onStoppedReturn) { in onStopped()
119 public void onMessageReceived(Mqtt5Client client, PublishReturn publishReturn) { in onMessageReceived()
182 try (Mqtt5Client client = new Mqtt5Client(optionsBuilder.build())) { in main()
|
| /external/aws-crt-java/utils/Canary/src/main/java/canary/mqtt5/ |
| D | Mqtt5Canary.java | 63 static List<Mqtt5Client> clients = new ArrayList<Mqtt5Client>();
244 …public void onAttemptingConnect(Mqtt5Client client, OnAttemptingConnectReturn onAttemptingConnectR… in onAttemptingConnect()
247 …public void onConnectionSuccess(Mqtt5Client client, OnConnectionSuccessReturn onConnectionSuccessR… in onConnectionSuccess()
264 …public void onConnectionFailure(Mqtt5Client client, OnConnectionFailureReturn onConnectionFailureR… in onConnectionFailure()
272 … public void onDisconnection(Mqtt5Client client, OnDisconnectionReturn onDisconnectionReturn) { in onDisconnection()
281 public void onStopped(Mqtt5Client client, OnStoppedReturn onStoppedReturn) { in onStopped()
292 public void onMessageReceived(Mqtt5Client client, PublishReturn publishReturn) { in onMessageReceived()
364 Mqtt5Client newClient = new Mqtt5Client(clientOptionsBuilder.build()); in setupClients()
396 Mqtt5Client client = clients.get(clientIdx); in OperationStart()
423 Mqtt5Client client = clients.get(clientIdx); in OperationStop()
[all …]
|
| /external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/ |
| D | MqttConnectionConfig.java | 14 import software.amazon.awssdk.crt.mqtt5.Mqtt5Client;
27 private Mqtt5Client mqtt5Client;
324 public void setMqtt5Client(Mqtt5Client mqtt5Client) { in setMqtt5Client()
334 public Mqtt5Client getMqtt5Client() { in getMqtt5Client()
|
| D | MqttClientConnection.java | 17 import software.amazon.awssdk.crt.mqtt5.Mqtt5Client;
124 …public MqttClientConnection(Mqtt5Client mqtt5client, MqttClientConnectionEvents callbacks) throws … in MqttClientConnection()
|