Skip to content

Commit

Permalink
We should sequentialize processing of messages for a thing as soon as we
Browse files Browse the repository at this point in the history
get a modifying signal

* This guarantees that the next signal can be aware of the changes of the
  previous one

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
  • Loading branch information
Yannic92 committed Jul 18, 2022
1 parent 9e95560 commit b95498b
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -588,7 +588,8 @@ private void enforceAndForwardToTargetActor(final Object message) {
*/
protected boolean shouldBecomeTwinSignalProcessingAwaiting(final Signal<?> signal) {
return !Signal.isChannelLive(signal) && !Signal.isChannelSmart(signal) &&
signal.getDittoHeaders().isResponseRequired();
signal instanceof Command<?> command &&
Command.Category.isEntityModifyingCommand(command.getCategory());
}

private void handleSignalEnforcementResponse(@Nullable final Object response,
Expand Down

0 comments on commit b95498b

Please sign in to comment.