1 files changed, 4 insertions, 2 deletions
diff --git a/lib/tapicero/user_database.rb b/lib/tapicero/user_database.rb
index 4061292..7e205ad 100644
--- a/lib/tapicero/user_database.rb
+++ b/lib/tapicero/user_database.rb
@@ -1,5 +1,6 @@
 require 'couchrest'
 require 'json'
+require 'tapicero/replication'
 
 module Tapicero
   class UserDatabase
@@ -27,9 +28,10 @@ module Tapicero
     def replicate()
       return unless config.options[:mode] == 'mirror'
       replication = config.options[:replication]
-      replication[:masters].each do |key, node|
+      replication["masters"].each do |key, node|
+        node["name"] = name
         retry_request_once "Replicating" do
-          Replication.new(source, name).run continuous: true
+          Tapicero::Replication.new(node, name).run continuous: true
         end
       end
     end