Hi, TD and other streaming developers,
When I look at the implementation of actor-based receiver
(ActorReceiver.scala), I found that there are several messages which are not
mentioned in the document
case props: Props =>
val worker = context.actorOf(props)
logInfo("Started receiver worker at:" + worker.path)
sender ! worker
case (props: Props, name: String) =>
val worker = context.actorOf(props, name)
logInfo("Started receiver worker at:" + worker.path)
sender ! worker
case _: PossiblyHarmful => hiccups.incrementAndGet()
case _: Statistics =>
val workers = context.children
sender ! Statistics(n.get, workers.size, hiccups.get, workers.mkString("\n”))
Is it hided with intention or incomplete document, or I missed something?
And the handler of these messages are “buggy"? e.g. when we start a new worker,
we didn’t increase n (counter of children), and n and hiccups are unnecessarily
set to AtomicInteger ?
Best,
--
Nan Zhu
http://codingcat.me
