raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=remote Clean up unused field.

Browse source
This commit is contained in:
He-Pin 2023-09-09 12:56:09 +08:00 • committed by kerr
parent e9ab2cc486
commit d0099a1b5c
1 changed files with 1 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

7
remote/src/main/scala/org/apache/pekko/remote/transport/netty/NettyTransport.scala
View file

@ -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))