diff --git a/services/src/main/java/io/scalecube/services/Microservices.java b/services/src/main/java/io/scalecube/services/Microservices.java index 8fe291278..522ebb1ed 100644 --- a/services/src/main/java/io/scalecube/services/Microservices.java +++ b/services/src/main/java/io/scalecube/services/Microservices.java @@ -539,7 +539,7 @@ public Context defaultPrincipalMapper( } private Context conclude() { - if (isConcluded.compareAndSet(false, true)) { + if (!isConcluded.compareAndSet(false, true)) { throw new IllegalStateException("Context is already concluded"); }