diff --git a/src/main/java/io/bitsquare/msg/tomp2p/TomP2PNode.java b/src/main/java/io/bitsquare/msg/tomp2p/TomP2PNode.java
index 94af8315b7..bc36fdd062 100644
--- a/src/main/java/io/bitsquare/msg/tomp2p/TomP2PNode.java
+++ b/src/main/java/io/bitsquare/msg/tomp2p/TomP2PNode.java
@@ -44,7 +44,6 @@ import javax.inject.Inject;
 
 import javafx.application.Platform;
 
-import net.tomp2p.connection.PeerConnection;
 import net.tomp2p.dht.FutureGet;
 import net.tomp2p.dht.FuturePut;
 import net.tomp2p.dht.FutureRemove;
@@ -52,7 +51,6 @@ import net.tomp2p.dht.PeerDHT;
 import net.tomp2p.futures.BaseFuture;
 import net.tomp2p.futures.BaseFutureListener;
 import net.tomp2p.futures.FutureDirect;
-import net.tomp2p.futures.FuturePeerConnection;
 import net.tomp2p.peers.Number160;
 import net.tomp2p.peers.PeerAddress;
 import net.tomp2p.peers.PeerSocketAddress;
@@ -204,9 +202,7 @@ public class TomP2PNode implements ClientNode {
 
     public FutureDirect sendData(PeerAddress peerAddress, Object payLoad) {
         log.trace("sendData");
-        FuturePeerConnection futurePeerConnection = peerDHT.peer().createPeerConnection(peerAddress,
-                PeerConnection.HEART_BEAT_MILLIS);
-        FutureDirect futureDirect = peerDHT.peer().sendDirect(futurePeerConnection).object(payLoad).start();
+        FutureDirect futureDirect = peerDHT.peer().sendDirect(peerAddress).object(payLoad).start();
         futureDirect.addListener(new BaseFutureListener<BaseFuture>() {
             @Override
             public void operationComplete(BaseFuture future) throws Exception {
diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml
index 13f9642f08..c5b4b54912 100644
--- a/src/main/resources/logback.xml
+++ b/src/main/resources/logback.xml
@@ -26,7 +26,7 @@
     <logger name="io.bitsquare" level="TRACE"/>
 
     <logger name="org.bitcoinj" level="INFO"/>
-    <logger name="net.tomp2p" level="TRACE"/>
+    <logger name="net.tomp2p" level="WARN"/>
 
 
     <logger name="net.tomp2p.message.Encoder" level="WARN"/>