Class: Dionysus::Consumer::ParamsBatchTransformations::RemoveDuplicatesStrategy

Inherits:
Object
  • Object
show all
Defined in:
lib/dionysus/consumer/params_batch_transformations/remove_duplicates_strategy.rb

Instance Method Summary collapse

Instance Method Details

#call(params_batch) ⇒ Object 



4
5
6
7
8
 
# File 'lib/dionysus/consumer/params_batch_transformations/remove_duplicates_strategy.rb', line 4

def call(params_batch)
  return params_batch if duplicates_removal_not_applicable?(params_batch)

  Karafka::Messages::Messages.new(transform_messages_array(params_batch), params_batch.metadata)
end