Skip to content

Commit

Permalink
start ack aggregator for thing twin modify commands and live messages
Browse files Browse the repository at this point in the history
* If we'd start the aggregator for policy commands this will fail
  as the responses can't be transformed to an acknowledgement

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
  • Loading branch information
Yannic92 committed Aug 8, 2022
1 parent 267f310 commit 02d61a8
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -159,6 +159,7 @@ public static boolean shouldStartForIncoming(final Signal<?> signal) {
result = !ackRequests.isEmpty();
} else if (signal instanceof Command<?> command &&
Command.Category.isEntityModifyingCommand(command.getCategory()) &&
Command.isThingCommand(signal) &&
!isLiveSignal) {
result = ackRequests.stream().anyMatch(AcknowledgementForwarderActorStarter::isNotLiveResponse);
} else if (Command.isMessageCommand(signal) || isLiveSignal && Command.isThingCommand(signal)) {
Expand Down

0 comments on commit 02d61a8

Please sign in to comment.