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

Only send message bundle if not stopped

Browse source
This commit is contained in:
Florian Reimair 2020-03-26 17:01:43 +01:00
parent 4ff4801e5c
commit 50ba2cd740
No known key found for this signature in database
GPG key ID: 05634D8D7A7954C8
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
p2p/src/main/java/bisq/network/p2p/network/Connection.java
View file

@ -284,7 +284,7 @@ public class Connection implements HasCapabilities, Runnable, MessageListener {
if (!stopped) {
synchronized (lock) {
BundleOfEnvelopes current = queueOfBundles.poll();
if (current != null) {
if (current != null && !stopped) {
if (current.getEnvelopes().size() == 1) {
protoOutputStream.writeEnvelope(current.getEnvelopes().get(0));
} else {