From d0099a1b5c84cd4a2528ebfbd8d036654ec812c0 Mon Sep 17 00:00:00 2001 From: He-Pin Date: Sat, 9 Sep 2023 12:56:09 +0800 Subject: [PATCH] =remote Clean up unused field. --- .../pekko/remote/transport/netty/NettyTransport.scala | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) 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))