Don't be specific about the kind of remoting in StreamRefsSpec (#25991)

This commit is contained in:
Arnout Engelen 2018-11-30 08:50:40 +01:00 committed by Christopher Batey
parent e940643c12
commit 5c653e1404

View file

@ -155,7 +155,6 @@ object StreamRefsSpec {
final case class BulkSinkMsg(dataSink: SinkRef[ByteString])
def config(): Config = {
val address = SocketUtil.temporaryServerAddress()
ConfigFactory.parseString(
s"""
akka {
@ -167,16 +166,9 @@ object StreamRefsSpec {
default-mailbox.mailbox-type = "akka.dispatch.UnboundedMailbox"
}
remote {
artery {
enabled = on
transport = aeron-udp
canonical.hostname = "${address.getHostName}"
canonical.port = ${address.getPort}
log-received-messages = on
log-sent-messages = on
}
artery.canonical.port = 0
netty.tcp.port = 0
}
}
""").withFallback(ConfigFactory.load())