Method: RR::ReplicationRun#install_sweeper

Defined in:
lib/rubyrep/replication_run.rb

#install_sweeper ⇒ Object

Installs the current sweeper into the database connections



98
99
100
101
102
103
104
105
 
# File 'lib/rubyrep/replication_run.rb', line 98

def install_sweeper
  [:left, :right].each do |database|
    unless session.send(database).respond_to?(:sweeper)
      session.send(database).send(:extend, NoisyConnection)
    end
    session.send(database).sweeper = sweeper
  end
end