mirrors/bisq
1
0
Fork 0
mirror of https://github.com/bisq-network/bisq.git synced 2024-11-20 10:22:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

Dont remove listener on fault

Browse Source
This commit is contained in:
Manfred Karrer 2016-05-25 15:52:40 +02:00
parent be3fc1998f
commit 39d6c1dc9b
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
network/src/main/java/io/bitsquare/p2p/P2PService.java
View File

@ -375,9 +375,11 @@ public class P2PService implements SetupListener, MessageListener, ConnectionLis
log.info("\n\nDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDD\n" +
"Decrypted SealedAndSignedMessage:\ndecryptedMsgWithPubKey={}"
+ "\nDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDDD\n", decryptedMsgWithPubKey);
connection.getPeersNodeAddressOptional().ifPresent(peersNodeAddress ->
decryptedDirectMessageListeners.stream().forEach(
e -> e.onDirectMessage(decryptedMsgWithPubKey, peersNodeAddress)));
if (connection.getPeersNodeAddressOptional().isPresent())
decryptedDirectMessageListeners.stream().forEach(
e -> e.onDirectMessage(decryptedMsgWithPubKey, connection.getPeersNodeAddressOptional().get()));
else
log.error("peersNodeAddress is not available at onMessage.");
} else {
log.info("Wrong receiverAddressMaskHash. The message is not intended for us.");
}
@ -778,7 +780,7 @@ public class P2PService implements SetupListener, MessageListener, ConnectionLis
@VisibleForTesting
@Nullable
public KeyRing getKeyRing() {
return optionalKeyRing.isPresent()? optionalKeyRing.get() : null;
return optionalKeyRing.isPresent() ? optionalKeyRing.get() : null;
}
///////////////////////////////////////////////////////////////////////////////////////////