From 03deffa95530d102bcc830861b9832157294667e Mon Sep 17 00:00:00 2001 From: Qian Hong Date: Wed, 29 Mar 2017 18:47:47 +1100 Subject: [PATCH] MQSecurityTest: Make sure no actual message is received. --- .../kotlin/net/corda/services/messaging/MQSecurityTest.kt | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/node/src/integration-test/kotlin/net/corda/services/messaging/MQSecurityTest.kt b/node/src/integration-test/kotlin/net/corda/services/messaging/MQSecurityTest.kt index d9b74d0894..daace87216 100644 --- a/node/src/integration-test/kotlin/net/corda/services/messaging/MQSecurityTest.kt +++ b/node/src/integration-test/kotlin/net/corda/services/messaging/MQSecurityTest.kt @@ -35,6 +35,7 @@ import org.junit.Before import org.junit.Test import java.util.* import java.util.concurrent.locks.ReentrantLock +import kotlin.test.assertEquals /** * Runs a series of MQ-related attacks against a node. Subclasses need to call [startAttacker] to connect @@ -201,10 +202,12 @@ abstract class MQSecurityTest : NodeBasedTest() { fun assertSendAttackFails(address: String) { val message = attacker.createMessage() + assertEquals(true, attacker.producer.isBlockOnNonDurableSend()) assertAttackFails(address, "SEND") { attacker.producer.send(address, message) } - // TODO Make sure no actual message is received + assertEquals(0, message.getDeliveryCount()) + assertEquals(0, message.getBodySize()) } fun assertConsumeAttackFails(queue: String) {