Class: MessageBusClientWorker::Polling::SetLastId

Inherits:
Object
  • Object
show all
Defined in:
lib/message_bus_client_worker/services/polling/set_last_id.rb

Constant Summary collapse

CHANNEL_INDICES_NAME = 
"message_bus_client_worker_channel_indices".freeze

Class Method Summary collapse

Class Method Details

.call(host, channel, message_id) ⇒ Object 



6
7
8
9
10
11
12
13
14
 
# File 'lib/message_bus_client_worker/services/polling/set_last_id.rb', line 6

def self.call(host, channel, message_id)
  hash_key = GenLastIdKey.(host, channel)

  id = Sidekiq.redis do |r|
    r.hset(CHANNEL_INDICES_NAME, hash_key, message_id)
  end

  id || "0"
end