Browse Source
Merge pull request #1587 from thingsboard/bug/fix-for-double-ack
Fixed doulbe PUBACK for attribute request messages
pull/1594/head
Igor Kulikov
8 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
1 additions and
1 deletions
-
common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/session/GatewaySessionHandler.java
|
|
@ -279,10 +279,10 @@ public class GatewaySessionHandler { |
|
|
|
|
|
|
|
|
@Override |
|
|
@Override |
|
|
public void onFailure(Throwable t) { |
|
|
public void onFailure(Throwable t) { |
|
|
|
|
|
ack(msg); |
|
|
log.debug("[{}] Failed to process device attributes request command: {}", sessionId, deviceName, t); |
|
|
log.debug("[{}] Failed to process device attributes request command: {}", sessionId, deviceName, t); |
|
|
} |
|
|
} |
|
|
}, context.getExecutor()); |
|
|
}, context.getExecutor()); |
|
|
ack(msg); |
|
|
|
|
|
} else { |
|
|
} else { |
|
|
throw new JsonSyntaxException(CAN_T_PARSE_VALUE + json); |
|
|
throw new JsonSyntaxException(CAN_T_PARSE_VALUE + json); |
|
|
} |
|
|
} |
|
|
|