Class: Karafka::Persistence::Consumer

Inherits:

Object

• Object
• Karafka::Persistence::Consumer

Defined in:

lib/karafka/persistence/consumer.rb

Overview

Persistence layer to store current thread messages consumer for further use

Constant Summary

PERSISTENCE_SCOPE =

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

:consumer

Class Method Summary

• .read ⇒ Karafka::Connection::Consumer

  Persisted messages consumer.

• .write(consumer) ⇒ Karafka::Connection::Consumer

  Persisted messages consumer.

Class Method Details

.read ⇒ Karafka::Connection::Consumer

Returns persisted messages consumer.

Returns:

• (Karafka::Connection::Consumer) —

  persisted messages consumer

Raises:

• (Karafka::Errors::MissingConsumer) —

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

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

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

.write(consumer) ⇒ Karafka::Connection::Consumer

Returns persisted messages consumer.

Parameters:

• consumer (Karafka::Connection::Consumer) —

  messages consumer of a current thread

Returns:

• (Karafka::Connection::Consumer) —

  persisted messages consumer

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

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