Skip to content

Commit 61dde73

Browse files
committed
pr comment changes and add synchronized to wasControlAcquired()
1 parent 168911a commit 61dde73

2 files changed

Lines changed: 5 additions & 3 deletions

File tree

src/main/java/software/amazon/awssdk/crt/mqtt5/Mqtt5PublishAcknowledgementControlHandle.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ public class Mqtt5PublishAcknowledgementControlHandle {
1515
private final long controlId;
1616

1717
/**
18-
* Creates a new Mqtt5PublishAcknowledgementControlHandle. Only called from native/JNI code.
18+
* Creates a new Mqtt5PublishAcknowledgementControlHandle.
1919
*
2020
* @param controlId The native publish acknowledgement control ID returned by
2121
* aws_mqtt5_client_acquire_publish_acknowledgement.
@@ -25,7 +25,9 @@ public class Mqtt5PublishAcknowledgementControlHandle {
2525
}
2626

2727
/**
28-
* Returns the native publish acknowledgement control ID. Used internally by JNI.
28+
* Returns the native publish acknowledgement control ID, used by
29+
* {@link Mqtt5Client#invokePublishAcknowledgement(Mqtt5PublishAcknowledgementControlHandle)}
30+
* to pass the control ID to native code.
2931
*
3032
* @return The native publish acknowledgement control ID.
3133
*/

src/main/java/software/amazon/awssdk/crt/mqtt5/PublishReturn.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public synchronized Mqtt5PublishAcknowledgementControlHandle acquirePublishAckno
8282
*
8383
* @return {@code true} if the user acquired manual control of the PUBACK, {@code false} otherwise.
8484
*/
85-
private boolean wasControlAcquired() {
85+
private synchronized boolean wasControlAcquired() {
8686
return controlAcquired;
8787
}
8888

0 commit comments

Comments
 (0)