Fix Socks Proxy Tests

This commit is contained in:
Katelyn Baker 2018-05-19 12:44:03 +01:00
parent c84bb7ebe0
commit 956f798a74

View File

@ -314,9 +314,10 @@ class SocksTests {
clientKeystore, clientKeystore,
clientConfig.keyStorePassword, clientConfig.keyStorePassword,
clientTruststore, true, clientTruststore, true,
MAX_MESSAGE_SIZE,
socksProxyConfig = SocksProxyConfig(SocksProxyVersion.SOCKS5, socksProxyConfig = SocksProxyConfig(SocksProxyVersion.SOCKS5,
NetworkHostAndPort("127.0.0.1", socksPort), null, null), NetworkHostAndPort("127.0.0.1", socksPort), null, null)
maxMessageSize = MAX_MESSAGE_SIZE) )
} }
private fun createSharedThreadsClient(sharedEventGroup: EventLoopGroup, id: Int): AMQPClient { private fun createSharedThreadsClient(sharedEventGroup: EventLoopGroup, id: Int): AMQPClient {
@ -337,10 +338,14 @@ class SocksTests {
PEER_USER, PEER_USER,
clientKeystore, clientKeystore,
clientConfig.keyStorePassword, clientConfig.keyStorePassword,
clientTruststore, true, true, sharedEventGroup, clientTruststore,
true,
MAX_MESSAGE_SIZE,
true,
sharedEventGroup,
socksProxyConfig = SocksProxyConfig(SocksProxyVersion.SOCKS5, socksProxyConfig = SocksProxyConfig(SocksProxyVersion.SOCKS5,
NetworkHostAndPort("127.0.0.1", socksPort), null, null), NetworkHostAndPort("127.0.0.1", socksPort), null, null)
maxMessageSize = MAX_MESSAGE_SIZE) )
} }
private fun createServer(port: Int, name: CordaX500Name = ALICE_NAME): AMQPServer { private fun createServer(port: Int, name: CordaX500Name = ALICE_NAME): AMQPServer {
@ -363,7 +368,6 @@ class SocksTests {
serverConfig.keyStorePassword, serverConfig.keyStorePassword,
serverTruststore, serverTruststore,
true, true,
false,
MAX_MESSAGE_SIZE) MAX_MESSAGE_SIZE)
} }
} }