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