diff --git a/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala b/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala index b33dbff3c4..6e0300ca13 100644 --- a/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala +++ b/remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala @@ -14,7 +14,7 @@ package org.apache.pekko.remote.transport.netty import java.net.{ InetAddress, InetSocketAddress, SocketAddress } -import java.util.concurrent.{ CancellationException, ConcurrentHashMap, Executors } +import java.util.concurrent.{ CancellationException, Executors } import java.util.concurrent.atomic.AtomicInteger import scala.annotation.nowarn @@ -358,11 +358,6 @@ class NettyTransport(val settings: NettyTransportSettings, val system: ExtendedA private val log = Logging.withMarker(system, classOf[NettyTransport]) - /** - * INTERNAL API - */ - private[netty] final val udpConnectionTable = new ConcurrentHashMap[SocketAddress, HandleEventListener]() - private def createExecutorService() = UseDispatcherForIo.map(system.dispatchers.lookup).getOrElse(Executors.newCachedThreadPool(system.threadFactory))