Class: Kafka::Retryable::Policies::KafkaHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/kafka/retryable/policies/kafka_handler.rb

Overview

Policy for storing failed messages in a queue on Kafka

Instance Method Summary collapse

Constructor Details

#initialize(message, topic) ⇒ KafkaHandler

Returns a new instance of KafkaHandler.



7
8
9
10
 
# File 'lib/kafka/retryable/policies/kafka_handler.rb', line 7

def initialize(message, topic)
  @message = message
  @topic = topic
end

Instance Method Details

#perform_failure_recovery ⇒ Object 



12
13
14
15
 
# File 'lib/kafka/retryable/policies/kafka_handler.rb', line 12

def perform_failure_recovery
  return unless Kafka::Retryable.enabled?
  Kafka::Retryable::MessageDispatcher::Kafka.new(@message, @topic).perform
end