mirror of
https://github.com/bisq-network/bisq.git
synced 2024-11-20 02:12:00 +01:00
Move log message closer to actual sending
This commit is contained in:
parent
e4ce976bab
commit
b814eff5f1
@ -88,8 +88,6 @@ public class RequestDataHandler implements MessageListener {
|
|||||||
else
|
else
|
||||||
getDataRequest = new GetUpdatedDataRequest(networkNode.getNodeAddress(), nonce);
|
getDataRequest = new GetUpdatedDataRequest(networkNode.getNodeAddress(), nonce);
|
||||||
|
|
||||||
log.info("We send a {} to peer {}. ", getDataRequest.getClass().getSimpleName(), nodeAddress);
|
|
||||||
|
|
||||||
if (timeoutTimer == null) { // setup before sending to avoid race conditions
|
if (timeoutTimer == null) { // setup before sending to avoid race conditions
|
||||||
timeoutTimer = UserThread.runAfter(() -> {
|
timeoutTimer = UserThread.runAfter(() -> {
|
||||||
if (!stopped) {
|
if (!stopped) {
|
||||||
@ -105,6 +103,7 @@ public class RequestDataHandler implements MessageListener {
|
|||||||
TIME_OUT_SEC);
|
TIME_OUT_SEC);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
log.info("We send a {} to peer {}. ", getDataRequest.getClass().getSimpleName(), nodeAddress);
|
||||||
SettableFuture<Connection> future = networkNode.sendMessage(nodeAddress, getDataRequest);
|
SettableFuture<Connection> future = networkNode.sendMessage(nodeAddress, getDataRequest);
|
||||||
Futures.addCallback(future, new FutureCallback<Connection>() {
|
Futures.addCallback(future, new FutureCallback<Connection>() {
|
||||||
@Override
|
@Override
|
||||||
|
Loading…
Reference in New Issue
Block a user