Make isFiltered thread safe

allegro · Aug 23, 2024 · 87b4d96 · 87b4d96
1 parent 888fd7e
commit 87b4d96
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/Message.java b/hermes-consumers/src/main/java/pl/allegro/tech/hermes/consumers/consumer/Message.java
@@ -22,8 +22,6 @@
 import java.util.Optional;
 import java.util.Set;
 
-import static java.util.stream.Collectors.toList;
-
 /**
  * Implementation note: this class is partially mutable and may be accessed from multiple
  * threads involved in message lifecycle, it must be thread safe.
@@ -208,11 +206,11 @@ public String getSubscription() {
         return subscription;
     }
 
-    public boolean isFiltered() {
+    public synchronized boolean isFiltered() {
         return isFiltered;
     }
 
-    public void setFiltered(boolean filtered) {
+    public synchronized void setFiltered(boolean filtered) {
         isFiltered = filtered;
     }