Thanks for your answer Roland, I'll keep the message logged so.
Le vendredi 10 octobre 2014 17:03:41 UTC+2, rkuhn a écrit : > > Yes, these messages are always there and they are harmless for all I can > see, we’ll eventually silence them > <https://github.com/akka/akka/issues/15163>. Thanks for giving feedback! > > Regards, > > Roland > > 9 okt 2014 kl. 15:42 skrev Xavier Bucchiotty <[email protected] > <javascript:>>: > > 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 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] <javascript:>. > To post to this group, send email to [email protected] > <javascript:>. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > > > > > *Dr. Roland Kuhn* > *Akka Tech Lead* > Typesafe <http://typesafe.com/> – Reactive apps on the JVM. > twitter: @rolandkuhn > <http://twitter.com/#!/rolandkuhn> > > -- >>>>>>>>>> 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.
