Class: Dynamiq::Client

Inherits:

Sidekiq::Client

Object
Sidekiq::Client
Dynamiq::Client

show all

Defined in:: lib/dynamiq/client.rb

Instance Method Summary collapse

#push_message(message) ⇒ Object

Instance Method Details

#push_message(message) ⇒ `Object`

# File 'lib/dynamiq/client.rb', line 3

def push_message(message)
  redis_pool.with do |conn|
    atomic_push conn, [ JSON.parse(message) ]
  end
end