Update nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.s…

…calastream/sinks/NsqSink.scala Co-authored-by: Benjamin BENOIST <[email protected]>
snowplow · Sep 19, 2023 · 0953c90 · 0953c90
1 parent 91d0c99
commit 0953c90
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala b/nsq/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/NsqSink.scala
@@ -44,7 +44,7 @@ class NsqSink[F[_]: Sync] private (
   topicName: String,
 ) extends Sink[F] {
 
-  var healthStatus = true
+  @volatile private var healthStatus = true
 
   override def isHealthy: F[Boolean] = Sync[F].pure(healthStatus)