Fix RPCStabilityTests.client doesnt leak threads when it fails to start (#2037)

This commit is contained in:
Andrzej Cichocki 2017-11-13 09:43:12 +00:00 committed by GitHub
parent 076a8ab937
commit d7ce405ec5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -48,7 +48,6 @@ import java.lang.reflect.Method
import java.nio.file.Path
import java.nio.file.Paths
import java.util.*
import javax.security.cert.X509Certificate
interface RPCDriverExposedDSLInterface : DriverDSLExposedInterface {
/**
@ -478,6 +477,7 @@ data class RPCDriverDSL(
): RpcServerHandle {
val locator = ActiveMQClient.createServerLocatorWithoutHA(brokerHandle.clientTransportConfiguration).apply {
minLargeMessageSize = ArtemisMessagingServer.MAX_FILE_SIZE
isUseGlobalPools = false
}
val userService = object : RPCUserService {
override fun getUser(username: String): User? = if (username == rpcUser.username) rpcUser else null