Sha256: 224dcf7abb5c467233ae6004c625df2ad64fe684d289a9a730b8c3eec83601ce
Contents?: true
Size: 955 Bytes
Versions: 116
Compression:
Stored size: 955 Bytes
Contents
# frozen_string_literal: true module SplitIoClient module Cache module Senders class EventsSender def initialize(events_repository, config) @events_repository = events_repository @config = config end def call events_thread end private def events_thread @config.threads[:events_sender] = Thread.new do begin @config.logger.info('Starting events service') loop do post_events sleep(SplitIoClient::Utilities.randomize_interval(@config.events_push_rate)) end rescue SplitIoClient::SDKShutdownException post_events @config.logger.info('Posting events due to shutdown') end end end def post_events @events_repository.post_events end end end end end
Version data entries
116 entries across 116 versions & 1 rubygems