class SplitIoClient::SSE::NotificationManagerKeeper

def process_event_occupancy(channel, publishers)
  @config.logger.debug("Processed occupancy event with #{publishers} publishers. Channel: #{channel}")
  update_publishers(channel, publishers)
  if !are_publishers_available? && @publisher_available.value
    @publisher_available.make_false
    push_status(Constants::PUSH_SUBSYSTEM_DOWN)
  elsif are_publishers_available? && !@publisher_available.value
    @publisher_available.make_true
    push_status(Constants::PUSH_SUBSYSTEM_READY)
  end
end