Sha256: e8e94d64e4ae9beb4f55c1610ade8b08c057fbcd6417560f31370e9587fe7b1e
Contents?: true
Size: 913 Bytes
Versions: 18
Compression:
Stored size: 913 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Persistence
# Persistence layer to store current thread messages consumer client for further use
class Client
# Thread.current key under which we store current thread messages consumer client
PERSISTENCE_SCOPE = :client
# @param client [Karafka::Connection::Client] messages consumer client of
# a current thread
# @return [Karafka::Connection::Client] persisted messages consumer client
def self.write(client)
Thread.current[PERSISTENCE_SCOPE] = client
end
# @return [Karafka::Connection::Client] persisted messages consumer client
# @raise [Karafka::Errors::MissingConsumer] raised when no thread messages consumer
# client but we try to use it anyway
def self.read
Thread.current[PERSISTENCE_SCOPE] || raise(Errors::MissingClient)
end
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems