removed some deprecations
This commit is contained in:
parent
b62f5f46f5
commit
20a819b637
11 changed files with 14 additions and 12 deletions
|
|
@ -822,7 +822,7 @@ final class IOManager private (system: ExtendedActorSystem) extends Extension {
|
|||
* IO. It communicates with other actors using subclasses of
|
||||
* [[akka.actor.IO.IOMessage]].
|
||||
*/
|
||||
val actor: ActorRef = system.actorOf(Props(new IOManagerActor(settings)), "io-manager")
|
||||
val actor: ActorRef = system.actorOf(Props(classOf[IOManagerActor], settings), "io-manager")
|
||||
|
||||
/**
|
||||
* Create a ServerSocketChannel listening on an address. Messages will be
|
||||
|
|
|
|||
|
|
@ -13,6 +13,8 @@ import scala.annotation.varargs
|
|||
import Deploy.{ NoDispatcherGiven, NoMailboxGiven }
|
||||
import scala.collection.immutable
|
||||
|
||||
import scala.language.existentials
|
||||
|
||||
/**
|
||||
* Factory for Props instances.
|
||||
*
|
||||
|
|
|
|||
|
|
@ -27,7 +27,7 @@ trait Inbox { this: ActorDSL.type ⇒
|
|||
val DSLInboxQueueSize = config.getInt("inbox-size")
|
||||
|
||||
val inboxNr = new AtomicInteger
|
||||
val inboxProps = Props(new InboxActor(DSLInboxQueueSize))
|
||||
val inboxProps = Props(classOf[InboxActor], DSLInboxQueueSize)
|
||||
|
||||
def newReceiver: ActorRef = mkChild(inboxProps, "inbox-" + inboxNr.incrementAndGet)
|
||||
}
|
||||
|
|
|
|||
|
|
@ -27,7 +27,7 @@ object IO {
|
|||
override def supervisorStrategy = connectionSupervisorStrategy
|
||||
|
||||
val selectorPool = context.actorOf(
|
||||
props = Props(new SelectionHandler(self, selectorSettings)).withRouter(RandomRouter(nrOfSelectors)),
|
||||
props = Props(classOf[SelectionHandler], self, selectorSettings).withRouter(RandomRouter(nrOfSelectors)),
|
||||
name = "selectors")
|
||||
|
||||
private def createWorkerMessage(pf: PartialFunction[HasFailureMessage, Props]): PartialFunction[HasFailureMessage, WorkerForCommand] = {
|
||||
|
|
|
|||
|
|
@ -222,7 +222,7 @@ class TcpExt(system: ExtendedActorSystem) extends IO.Extension {
|
|||
|
||||
val manager: ActorRef = {
|
||||
system.asInstanceOf[ActorSystemImpl].systemActorOf(
|
||||
props = Props(new TcpManager(this)).withDispatcher(Settings.ManagementDispatcher),
|
||||
props = Props(classOf[TcpManager], this).withDispatcher(Settings.ManagementDispatcher),
|
||||
name = "IO-TCP")
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -96,7 +96,7 @@ private[io] class TcpListener(val selectorRouter: ActorRef,
|
|||
if (socketChannel != null) {
|
||||
log.debug("New connection accepted")
|
||||
socketChannel.configureBlocking(false)
|
||||
selectorRouter ! WorkerForCommand(RegisterIncoming(socketChannel), self, Props(new TcpIncomingConnection(socketChannel, tcp, handler, options)))
|
||||
selectorRouter ! WorkerForCommand(RegisterIncoming(socketChannel), self, Props(classOf[TcpIncomingConnection], socketChannel, tcp, handler, options))
|
||||
acceptAllPending(limit - 1)
|
||||
} else context.parent ! AcceptInterest
|
||||
}
|
||||
|
|
|
|||
|
|
@ -50,10 +50,10 @@ private[io] class TcpManager(tcp: TcpExt) extends SelectorBasedManager(tcp.Setti
|
|||
def receive = workerForCommandHandler {
|
||||
case c: Connect ⇒
|
||||
val commander = sender
|
||||
Props(new TcpOutgoingConnection(tcp, commander, c))
|
||||
Props(classOf[TcpOutgoingConnection], tcp, commander, c)
|
||||
case b: Bind ⇒
|
||||
val commander = sender
|
||||
Props(new TcpListener(selectorPool, tcp, commander, b))
|
||||
Props(classOf[TcpListener], selectorPool, tcp, commander, b)
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -106,7 +106,7 @@ class UdpExt(system: ExtendedActorSystem) extends IO.Extension {
|
|||
|
||||
val manager: ActorRef = {
|
||||
system.asInstanceOf[ActorSystemImpl].systemActorOf(
|
||||
props = Props(new UdpManager(this)),
|
||||
props = Props(classOf[UdpManager], this),
|
||||
name = "IO-UDP-FF")
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -64,7 +64,7 @@ class UdpConnectedExt(system: ExtendedActorSystem) extends IO.Extension {
|
|||
|
||||
val manager: ActorRef = {
|
||||
system.asInstanceOf[ActorSystemImpl].systemActorOf(
|
||||
props = Props(new UdpConnectedManager(this)),
|
||||
props = Props(classOf[UdpConnectedManager], this),
|
||||
name = "IO-UDP-CONN")
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -15,7 +15,7 @@ private[io] class UdpConnectedManager(udpConn: UdpConnectedExt) extends Selector
|
|||
def receive = workerForCommandHandler {
|
||||
case c: Connect ⇒
|
||||
val commander = sender
|
||||
Props(new UdpConnection(udpConn, commander, c))
|
||||
Props(classOf[UdpConnection], udpConn, commander, c)
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
|
|
@ -49,10 +49,10 @@ private[io] class UdpManager(udp: UdpExt) extends SelectorBasedManager(udp.setti
|
|||
def receive = workerForCommandHandler {
|
||||
case b: Bind ⇒
|
||||
val commander = sender
|
||||
Props(new UdpListener(udp, commander, b))
|
||||
Props(classOf[UdpListener], udp, commander, b)
|
||||
case SimpleSender(options) ⇒
|
||||
val commander = sender
|
||||
Props(new UdpSender(udp, options, commander))
|
||||
Props(classOf[UdpSender], udp, options, commander)
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue