Home
last modified time | relevance | path

Searched refs:MqttMessage (Results 1 – 10 of 10) sorted by relevance

/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/
DMqttMessage.java10 public final class MqttMessage { class
33 …public MqttMessage(String topic, byte[] payload, QualityOfService qos, boolean retain, boolean dup… in MqttMessage() method in MqttMessage
54 public MqttMessage(String topic, byte[] payload, QualityOfService qos, boolean retain) { in MqttMessage() method in MqttMessage
67 public MqttMessage(String topic, byte[] payload, QualityOfService qos) { in MqttMessage() method in MqttMessage
77 public MqttMessage(String topic, byte[] payload) { in MqttMessage() method in MqttMessage
DMqttClientConnection.java44 Consumer<MqttMessage> callback;
46 private MessageHandler(Consumer<MqttMessage> callback) { in MessageHandler()
53 callback.accept(new MqttMessage(topic, payload, qosEnum, retain, dup)); in deliver()
170 MqttMessage message = config.getWillMessage(); in SetupConfig()
350 …tableFuture<Integer> subscribe(String topic, QualityOfService qos, Consumer<MqttMessage> handler) { in subscribe()
387 public void onMessage(Consumer<MqttMessage> handler) { in onMessage()
419 public CompletableFuture<Integer> publish(MqttMessage message) { in publish()
438 …public CompletableFuture<Integer> publish(MqttMessage message, QualityOfService qos, boolean retai… in publish()
439 return publish(new MqttMessage(message.getTopic(), message.getPayload(), qos, retain)); in publish()
DMqttConnectionConfig.java40 private MqttMessage willMessage;
390 public void setWillMessage(MqttMessage willMessage) { in setWillMessage()
399 public MqttMessage getWillMessage() { in getWillMessage()
405 return new MqttMessage(willMessage.getTopic(), willMessage.getPayload(), qos, retain); in getWillMessage()
/external/aws-crt-java/src/test/java/software/amazon/awssdk/crt/test/
DSelfPubSubTest.java19 import software.amazon.awssdk.crt.mqtt.MqttMessage;
61 CompletableFuture<MqttMessage> receivedFuture = new CompletableFuture<>(); in testPubSub()
62 Consumer<MqttMessage> messageHandler = (message) -> { in testPubSub()
74 …MqttMessage message = new MqttMessage(TEST_TOPIC, TEST_PAYLOAD.getBytes(), QualityOfService.AT_LEA… in testPubSub()
90 MqttMessage received = receivedFuture.get(); in testPubSub()
118 Consumer<MqttMessage> messageHandler = (message) -> { in testPubSubOnMessage()
151 …MqttMessage message = new MqttMessage(TEST_TOPIC, TEST_PAYLOAD.getBytes(), QualityOfService.AT_LEA… in testPubSubOnMessage()
DPublishTest.java43 ArrayList<MqttMessage> receivedMessages = new ArrayList<>();
45 private void onPublishHandler(MqttMessage message) { in onPublishHandler()
65 … MqttMessage message = new MqttMessage(TEST_TOPIC, payload, QualityOfService.AT_LEAST_ONCE); in publishAndCheck()
75 MqttMessage received = receivedMessages.get(0); in publishAndCheck()
DWillTest.java18 import software.amazon.awssdk.crt.mqtt.MqttMessage;
40 …config.setWillMessage(new MqttMessage(TEST_TOPIC, TEST_WILL.getBytes(), QualityOfService.AT_LEAST_… in testWill()
64 …config.setWillMessage(new MqttMessage(TEST_TOPIC, TEST_EMPTY_WILL.getBytes(), QualityOfService.AT_… in testEmptyWill()
88 … config.setWillMessage(new MqttMessage(TEST_TOPIC, null, QualityOfService.AT_LEAST_ONCE)); in testNullWill()
DMqtt5to3AdapterConnectionTest.java47 import software.amazon.awssdk.crt.mqtt.MqttMessage;
100 Consumer<MqttMessage> connectionMessageTransfomer = null;
102 void setConnectionMessageTransformer(Consumer<MqttMessage> connectionMessageTransfomer) { in setConnectionMessageTransformer()
664 Consumer<MqttMessage> messageHandler = (message) -> { in TestOperationSubUnsub()
698 CompletableFuture<MqttMessage> receivedFuture = new CompletableFuture<>(); in TestOperationSubUnsub()
699 Consumer<MqttMessage> subscriberMessageHandler = (message) -> { in TestOperationSubUnsub()
711 …MqttMessage message = new MqttMessage(testTopic, testPayload.getBytes(), QualityOfService.AT_LEAST… in TestOperationSubUnsub()
727 MqttMessage received = receivedFuture.get(); in TestOperationSubUnsub()
761 Consumer<MqttMessage> messageHandler = (message) -> { in TestAnauthorizedSub()
795 CompletableFuture<MqttMessage> receivedFuture = new CompletableFuture<>(); in TestAnauthorizedSub()
[all …]
DIotServiceTest.java15 import software.amazon.awssdk.crt.mqtt.MqttMessage;
35 Consumer<MqttMessage> messageHandler = (message) -> {}; in testIotService()
DSubscribeTest.java17 import software.amazon.awssdk.crt.mqtt.MqttMessage;
53 Consumer<MqttMessage> messageHandler = (message) -> {}; in testSubscribeUnsubscribe()
DMqttClientConnectionFixture.java140 Consumer<MqttMessage> connectionMessageTransfomer = null;
141 …protected void setConnectionMessageTransformer(Consumer<MqttMessage> connectionMessageTransfomer) { in setConnectionMessageTransformer()
394 MqttMessage messageToSend = new MqttMessage(topic, payload, qos); in publish()