Class: MessageBusClientWorker::Polling::GetLastId

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

Class Method Summary collapse

Class Method Details

.call(host:, channel:, headers: {}) ⇒ Object



5
6
7
8
# File 'lib/message_bus_client_worker/services/polling/get_last_id.rb', line 5

def self.call(host:, channel:, headers: {})
  hash_key = GenLastIdKey.(host: host, channel: channel, headers: headers)
  Sidekiq.redis { |r| r.hget(SetLastId::CHANNEL_INDICES_NAME, hash_key) }
end