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:, headers:) ⇒ 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:, headers:)
  hash_key = GenLastIdKey.(host: host, channel: channel, headers: headers)

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

  id || "0"
end