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