ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-21 09:51:57 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MQSecurityTest: Make sure no actual message is received.

Browse Source
This commit is contained in:
Qian Hong 2017-03-29 18:47:47 +11:00 committed by Mike Hearn
parent ade9a7dba8
commit 03deffa955
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
node/src/integration-test/kotlin/net/corda/services/messaging/MQSecurityTest.kt
View File

@ -35,6 +35,7 @@ import org.junit.Before
import org.junit.Test import org.junit.Test
import java.util.* import java.util.*
import java.util.concurrent.locks.ReentrantLock 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 * 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) { fun assertSendAttackFails(address: String) {
val message = attacker.createMessage() val message = attacker.createMessage()
assertEquals(true, attacker.producer.isBlockOnNonDurableSend())
assertAttackFails(address, "SEND") { assertAttackFails(address, "SEND") {
attacker.producer.send(address, message) 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) { fun assertConsumeAttackFails(queue: String) {