From f8070b08111553f0d81ae22d31645c9748627c74 Mon Sep 17 00:00:00 2001 From: Patrick Date: Fri, 18 May 2018 12:02:00 +0100 Subject: [PATCH] fix test --- .../node/services/messaging/ArtemisMessagingTest.kt | 10 +++------- 1 file changed, 3 insertions(+), 7 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 3c9fd7fa9a..5c7263609f 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 @@ -18,10 +18,6 @@ import net.corda.core.utilities.NetworkHostAndPort import net.corda.core.utilities.seconds import net.corda.node.internal.configureDatabase import net.corda.node.services.config.* -import net.corda.node.services.config.CertChainPolicyConfig -import net.corda.node.services.config.NodeConfiguration -import net.corda.node.services.config.P2PMessagingRetryConfiguration -import net.corda.node.services.config.configureWithDevSSLCertificate import net.corda.node.services.network.NetworkMapCacheImpl import net.corda.node.services.network.PersistentNetworkMapCache import net.corda.node.services.transactions.PersistentUniquenessProvider @@ -35,7 +31,6 @@ import net.corda.testing.node.MockServices.Companion.makeTestDataSourcePropertie import net.corda.testing.node.internal.MOCK_VERSION_INFO import org.apache.activemq.artemis.api.core.Message.HDR_VALIDATED_USER import org.apache.activemq.artemis.api.core.SimpleString -import org.apache.activemq.artemis.api.core.ActiveMQConnectionTimedOutException import org.assertj.core.api.Assertions.assertThat import org.assertj.core.api.Assertions.assertThatThrownBy import org.junit.After @@ -169,6 +164,7 @@ class ArtemisMessagingTest { assertNull(receivedMessages.poll(200, MILLISECONDS)) } + @Test fun `server should not process if incoming message exceed maxMessageSize limit`() { val (messagingClient, receivedMessages) = createAndStartClientAndServer(clientMaxMessageSize = 100_000, serverMaxMessageSize = 50_000) @@ -180,9 +176,9 @@ class ArtemisMessagingTest { assertNull(receivedMessages.poll(200, MILLISECONDS)) val tooLagerMessage = messagingClient.createMessage(TOPIC, data = ByteArray(100_000)) - assertThatThrownBy { + thread { messagingClient.send(tooLagerMessage, messagingClient.myAddress) - }.isInstanceOf(ActiveMQConnectionTimedOutException::class.java) + }.join(10.seconds.toMillis()) assertNull(receivedMessages.poll(200, MILLISECONDS)) }