Skip to content

Commit

Permalink
Issue #106: (WIP) Keep response receivers for *live* signal enforceme…
Browse files Browse the repository at this point in the history
…nt until evicted by cache.

This makes it possible to receive multiple responses for the same correlation ID in order to mitigate an invalid response with a subsequent valid response.

Signed-off-by: Juergen Fickel <juergen.fickel@bosch.io>
  • Loading branch information
Juergen Fickel committed Nov 19, 2021
1 parent a4d7406 commit 7d6cc4c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -203,7 +203,7 @@ private CompletionStage<Contextual<WithDittoHeaders>> returnCommandResponseConte
return responseReceivers.get(correlationId).thenApply(responseReceiverEntry -> {
final Contextual<WithDittoHeaders> commandResponseContextual;
if (responseReceiverEntry.isPresent()) {
responseReceivers.invalidate(correlationId);
// responseReceivers.invalidate(correlationId);
final Pair<ActorRef, AuthorizationContext> responseReceiver = responseReceiverEntry.get();
final CommandResponse<?> response;
if (liveResponse instanceof ThingQueryCommandResponse) {
Expand Down

0 comments on commit 7d6cc4c

Please sign in to comment.