class Synapse::Command::DuplicationFilter

Filter that prevents duplicate commands from reaching the command handlers

Public Class Methods

new(recorder) click to toggle source

@param [DuplicationRecorder] recorder @return [undefined]

# File lib/synapse/command/duplication.rb, line 7
def initialize(recorder)
  @recorder = recorder
end

Public Instance Methods

filter(command) click to toggle source

@param [CommandMessage] command @return [CommandMessage] The command to dispatch on the bus

# File lib/synapse/command/duplication.rb, line 13
def filter(command)
  @recorder.record command
  command
end