Contents

class Jason::OutboundMessageQueueWorker
  include Sidekiq::Worker if defined?(Sidekiq) # Even if not using Pusher, this gets autoloaded

  def perform
    batch = get_batch
    return if batch.size == 0

    Jason.pusher.trigger_batch(batch)
  end

  private

  def get_batch
    batch_json = $redis_jason.multi do |r|
      r.lrange("jason:outbound_message_queue", 0, 9) # get first 10 elements
      r.ltrim("jason:outbound_message_queue", 10, -1) # delete first 10 elements
    end[0]

    batch_json.map { |event| JSON.parse(event).with_indifferent_access } # Pusher wants symbol keys
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
jason-rails-0.7.5.1	app/workers/jason/outbound_message_queue_worker.rb
jason-rails-0.8.0	app/workers/jason/outbound_message_queue_worker.rb
jason-rails-0.7.5	app/workers/jason/outbound_message_queue_worker.rb
jason-rails-0.7.3	app/workers/jason/outbound_message_queue_worker.rb
jason-rails-0.7.2	app/workers/jason/outbound_message_queue_worker.rb
jason-rails-0.7.1	app/workers/jason/outbound_message_queue_worker.rb
jason-rails-0.7.0	app/workers/jason/outbound_message_queue_worker.rb