From fe0dcb510c245c58df48e4410c0b816353fe0475 Mon Sep 17 00:00:00 2001
From: Manfred Karrer <mk@nucleo.io>
Date: Thu, 13 Nov 2014 11:03:18 +0100
Subject: [PATCH] Add IndirectReplication

---
 src/main/java/io/bitsquare/app/cli/BootstrapNode.java        | 5 ++++-
 .../io/bitsquare/msg/tomp2p/BootstrappedPeerFactory.java     | 2 ++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/java/io/bitsquare/app/cli/BootstrapNode.java b/src/main/java/io/bitsquare/app/cli/BootstrapNode.java
index 296d7e55b0..b9ba80a7c8 100644
--- a/src/main/java/io/bitsquare/app/cli/BootstrapNode.java
+++ b/src/main/java/io/bitsquare/app/cli/BootstrapNode.java
@@ -20,6 +20,7 @@ package io.bitsquare.app.cli;
 import io.bitsquare.network.Node;
 
 import net.tomp2p.dht.PeerBuilderDHT;
+import net.tomp2p.dht.PeerDHT;
 import net.tomp2p.nat.PeerBuilderNAT;
 import net.tomp2p.p2p.Peer;
 import net.tomp2p.p2p.PeerBuilder;
@@ -27,6 +28,7 @@ import net.tomp2p.peers.Number160;
 import net.tomp2p.peers.PeerAddress;
 import net.tomp2p.peers.PeerMap;
 import net.tomp2p.peers.PeerMapConfiguration;
+import net.tomp2p.replication.IndirectReplication;
 import net.tomp2p.rpc.ObjectDataReply;
 
 import org.slf4j.Logger;
@@ -63,8 +65,9 @@ public class BootstrapNode {
                 }
             });
 
-            new PeerBuilderDHT(peer).start();
+            PeerDHT peerDHT = new PeerBuilderDHT(peer).start();
             new PeerBuilderNAT(peer).start();
+            new IndirectReplication(peerDHT).start();
 
             log.debug("started");
             new Thread(new Runnable() {
diff --git a/src/main/java/io/bitsquare/msg/tomp2p/BootstrappedPeerFactory.java b/src/main/java/io/bitsquare/msg/tomp2p/BootstrappedPeerFactory.java
index 337dfc7c65..1db13d20b4 100644
--- a/src/main/java/io/bitsquare/msg/tomp2p/BootstrappedPeerFactory.java
+++ b/src/main/java/io/bitsquare/msg/tomp2p/BootstrappedPeerFactory.java
@@ -59,6 +59,7 @@ import net.tomp2p.peers.PeerMap;
 import net.tomp2p.peers.PeerMapChangeListener;
 import net.tomp2p.peers.PeerMapConfiguration;
 import net.tomp2p.peers.PeerStatistic;
+import net.tomp2p.replication.IndirectReplication;
 import net.tomp2p.utils.Utils;
 
 import org.jetbrains.annotations.NotNull;
@@ -132,6 +133,7 @@ public class BootstrappedPeerFactory {
             peer = new PeerBuilder(keyPair).ports(port).peerMap(pm).bindings(bindings)
                     .channelClientConfiguration(cc).start();
             peerDHT = new PeerBuilderDHT(peer).start();
+            new IndirectReplication(peerDHT).start();
 
             peer.peerBean().peerMap().addPeerMapChangeListener(new PeerMapChangeListener() {
                 @Override