From a3e2aff080fde334f5c26534cf7200f8fb7da6e2 Mon Sep 17 00:00:00 2001 From: Andras Slemmer Date: Wed, 21 Feb 2018 11:50:34 +0000 Subject: [PATCH] Fix tests --- .../net/corda/node/services/messaging/ArtemisMessagingTest.kt | 1 - .../src/main/kotlin/net/corda/testing/node/MockNetwork.kt | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/node/src/test/kotlin/net/corda/node/services/messaging/ArtemisMessagingTest.kt b/node/src/test/kotlin/net/corda/node/services/messaging/ArtemisMessagingTest.kt index c6fad024f3..69afbb25b9 100644 --- a/node/src/test/kotlin/net/corda/node/services/messaging/ArtemisMessagingTest.kt +++ b/node/src/test/kotlin/net/corda/node/services/messaging/ArtemisMessagingTest.kt @@ -271,7 +271,6 @@ class ArtemisMessagingTest { createMessagingServer().start() val messagingClient = createMessagingClient(platformVersion = platformVersion) - startNodeMessagingClient() messagingClient.addMessageHandler(TOPIC) { message, _, handle -> database.transaction { handle.persistDeduplicationId() } handle.acknowledge() // We ACK first so that if it fails we won't get a duplicate in [receivedMessages] diff --git a/testing/node-driver/src/main/kotlin/net/corda/testing/node/MockNetwork.kt b/testing/node-driver/src/main/kotlin/net/corda/testing/node/MockNetwork.kt index 23d2f41fd2..d550695bc5 100644 --- a/testing/node-driver/src/main/kotlin/net/corda/testing/node/MockNetwork.kt +++ b/testing/node-driver/src/main/kotlin/net/corda/testing/node/MockNetwork.kt @@ -167,7 +167,7 @@ open class MockNetwork( @JvmOverloads constructor(cordappPackages: List, parameters: MockNetworkParameters = MockNetworkParameters()) : this(cordappPackages, defaultParameters = parameters) - private val internalMockNetwork: InternalMockNetwork = InternalMockNetwork(cordappPackages, defaultParameters, networkSendManuallyPumped, threadPerNode, servicePeerAllocationStrategy, notarySpecs) + private val internalMockNetwork: InternalMockNetwork = InternalMockNetwork(cordappPackages, defaultParameters, networkSendManuallyPumped, threadPerNode, servicePeerAllocationStrategy, notarySpecs, networkParameters) /** Which node will be used as the primary notary during transaction builds. */ val defaultNotaryNode get(): StartedMockNode = StartedMockNode.create(internalMockNetwork.defaultNotaryNode)