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

Version Path
splitclient-rb-8.5.0-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.5.0 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.5.0.pre.rc1-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.5.0.pre.rc1 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.1.pre.rc1-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.1.pre.rc1 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.0-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.0 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.0.pre.rc1-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.0.pre.rc1 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.0.rc.1-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.4.0.rc.1 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.2.pre.rc2-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.2.pre.rc2 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.2.pre.rc1-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.2.pre.rc1 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.1-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.1 lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.1.pre.rc1-java lib/splitclient-rb/cache/senders/events_sender.rb
splitclient-rb-8.3.1.pre.rc1 lib/splitclient-rb/cache/senders/events_sender.rb