ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-06-17 14:48:16 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

The logic in my recent late start bridge PR was wrong. This doesn't affect embedded bridges, but for external bridges the state doesn't reset correctly on bridge restart. (#3301)

Browse Source
This commit is contained in:
Matthew Nesbit
2018-06-05 13:30:20 +01:00
committed by GitHub
parent 086b9daa6e
commit 0812329aaf
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
node/src/main/kotlin/net/corda/node/services/messaging/P2PMessagingClient.kt
View File

@ -322,6 +322,7 @@ class P2PMessagingClient(val config: NodeConfiguration,
} }
val queues = session.addressQuery(SimpleString("$PEERS_PREFIX#")).queueNames val queues = session.addressQuery(SimpleString("$PEERS_PREFIX#")).queueNames
knownQueues.clear()
for (queue in queues) { for (queue in queues) {
val queueQuery = session.queueQuery(queue) val queueQuery = session.queueQuery(queue)
if (!config.lazyBridgeStart || queueQuery.messageCount > 0) { if (!config.lazyBridgeStart || queueQuery.messageCount > 0) {