From e30fd3d530f586c6d4efdedcc9d9a5fdc272a980 Mon Sep 17 00:00:00 2001 From: Konrad Malawski Date: Fri, 10 Aug 2018 12:32:06 +0900 Subject: [PATCH] =dns amend message for failing in wrong protocol use in dns --- .../src/main/scala/akka/io/SimpleDnsManager.scala | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/akka-actor/src/main/scala/akka/io/SimpleDnsManager.scala b/akka-actor/src/main/scala/akka/io/SimpleDnsManager.scala index eea5e0a1bc..1b2af5f3b8 100644 --- a/akka-actor/src/main/scala/akka/io/SimpleDnsManager.scala +++ b/akka-actor/src/main/scala/akka/io/SimpleDnsManager.scala @@ -42,13 +42,12 @@ class SimpleDnsManager(val ext: DnsExt) extends Actor with RequiresMessageQueue[ case m: dns.DnsProtocol.Resolve ⇒ if (inetDnsEnabled) { - log.info( - "Message of [akka.io.dns.DnsProtocol.Protocol] received ({}) while inet-address dns was configured. Dropping DNS resolve request." + - "Only use [akka.io.dns.DnsProtocol.resolve] to create resolution requests for the Async DNS resolver.", + log.error( + "Message of [akka.io.dns.DnsProtocol.Protocol] received ({}) while inet-address dns was configured. Dropping DNS resolve request. " + + "Only use [akka.io.dns.DnsProtocol] to create resolution requests for the Async DNS resolver (enabled by `akka.io.dns = async-dns`). " + + "For the classic (now used) DNS resolver use [akka.io.Dns] messages.", Logging.simpleName(m)) - } - - resolver.forward(m) + } else resolver.forward(m) } override def postStop(): Unit = {