We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f0b9c97 commit 8ad8992Copy full SHA for 8ad8992
1 file changed
lib/splitclient-rb/sse/notification_manager_keeper.rb
@@ -14,8 +14,8 @@ def initialize(config, telemetry_runtime_producer, status_queue)
14
@telemetry_runtime_producer = telemetry_runtime_producer
15
@status_queue = status_queue
16
@publisher_available = Concurrent::AtomicBoolean.new(true)
17
- @publishers_pri = Concurrent::AtomicFixnum.new(1)
18
- @publishers_sec = Concurrent::AtomicFixnum.new(1)
+ @publishers_pri = Concurrent::AtomicFixnum.new(2)
+ @publishers_sec = Concurrent::AtomicFixnum.new(2)
19
end
20
21
def handle_incoming_occupancy_event(event)
0 commit comments