Hello akka user group,
We've already posted some questions about streaming a file through
akka-stream. But we stilll need help from the community. Everything work
pretty weel but it seems that some internal messages of the flows go to
dead-letters at the end of the process. Every tests are ok and transfer is
completed with success.
Here are the logs
[INFO] [10/09/2014 15:22:45.057] [default-akka.actor.default-dispatcher-3]
[akka://default/user/$a/upload-flow-6-0-*iterator*] Message [
*akka.stream.impl.RequestMore*] from Actor[akka://default/deadLetters] to
Actor[akka://default/user/$a/upload-flow-6-0-iterator#-1507155652] was not
delivered. [1] dead letters encountered. This logging can be turned off or
adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
[INFO] [10/09/2014 15:22:45.057] [default-akka.actor.default-dispatcher-3]
[akka://default/user/$a/upload-flow-1-*broadcast*] Message [
*akka.stream.impl2.FanOut$SubstreamRequestMore*] from
Actor[akka://default/deadLetters] to
Actor[akka://default/user/$a/upload-flow-1-broadcast#-723207174] was not
delivered. [2] dead letters encountered. This logging can be turned off or
adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
[INFO] [10/09/2014 15:22:45.057] [default-akka.actor.default-dispatcher-3]
[akka://default/user/$a/upload-flow-1-*broadcast*] Message [
*akka.stream.impl2.FanOut$SubstreamRequestMore*] from
Actor[akka://default/deadLetters] to
Actor[akka://default/user/$a/upload-flow-1-broadcast#-723207174] was not
delivered. [3] dead letters encountered. This logging can be turned off or
adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
[INFO] [10/09/2014 15:22:45.057] [default-akka.actor.default-dispatcher-3]
[akka://default/user/$a/upload-flow-1-*broadcast*] Message*
[akka.stream.impl2.FanOut$SubstreamRequestMore]* from
Actor[akka://default/deadLetters] to
Actor[akka://default/user/$a/upload-flow-1-broadcast#-723207174] was not
delivered. [4] dead letters encountered. This logging can be turned off or
adjusted with configuration settings 'akka.log-dead-letters' and
'akka.log-dead-letters-during-shutdown'.
Here is our flow
FlowGraph { implicit builder =>
val broadcast = Broadcast[ByteString]
val in = IteratorSource(byteStream.grouped(100).map(bytes=> {
val builder = new ByteStringBuilder()
builder.sizeHint(bytes.length)
builder ++= bytes
builder.result()
}))
in ~> broadcast ~> *ForeachSink*(println)
broadcast ~> *OnCompleteSink*[ByteString] {
case _ => {
println("Complete.")
//Tried also with a Thread.sleep(1000) there. Dead letter messages come
after the call to system.shutdown()
system.shutdown()
}
}
}.run()
We use standard *ForeachSink* and *OnCompleteSink* here.
I've created a gist here <http://some
akka.stream.impl2.FanOut$SubstreamRequestMore messages with Broadcast in go
to deadletters> if you want to give it a try.
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
