mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2025-02-24 23:18:17 +01:00
Code Issues Projects Releases Packages Wiki Activity

Remove PeerConnection for sendDirect

Browse source
This commit is contained in:
Manfred Karrer 2014-11-17 02:30:47 +01:00
parent 8e18a265de
commit 97fc4a728e
2 changed files with 2 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/main/java/io/bitsquare/msg/tomp2p/TomP2PNode.java
View file

@ -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 {

2
src/main/resources/logback.xml
View file

@ -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"/>