Class: Karafka::Persistence::Client

Inherits:

Object

• Object
• Karafka::Persistence::Client

Defined in:

lib/karafka/persistence/client.rb

Overview

Persistence layer to store current thread messages consumer client for further use

Constant Summary

PERSISTENCE_SCOPE =

Thread.current key under which we store current thread messages consumer client

:client

Class Method Summary

• .read ⇒ Karafka::Connection::Client

  Persisted messages consumer client.

• .write(client) ⇒ Karafka::Connection::Client

  Persisted messages consumer client.

Class Method Details

.read ⇒ Karafka::Connection::Client

Returns persisted messages consumer client.

Returns:

• (Karafka::Connection::Client) —

  persisted messages consumer client

Raises:

• (Karafka::Errors::MissingConsumer) —

  raised when no thread messages consumer client but we try to use it anyway

# File 'lib/karafka/persistence/client.rb', line 20

def self.read
  Thread.current[PERSISTENCE_SCOPE] || raise(Errors::MissingClient)
end

.write(client) ⇒ Karafka::Connection::Client

Returns persisted messages consumer client.

Parameters:

• client (Karafka::Connection::Client) —

  messages consumer client of a current thread

Returns:

• (Karafka::Connection::Client) —

  persisted messages consumer client

# File 'lib/karafka/persistence/client.rb', line 13

def self.write(client)
  Thread.current[PERSISTENCE_SCOPE] = client
end