Yes, these messages are always there and they are harmless for all I can see, we’ll eventually silence them. Thanks for giving feedback!
Regards, Roland 9 okt 2014 kl. 15:42 skrev Xavier Bucchiotty <[email protected]>: > 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]. > 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. Dr. Roland Kuhn Akka Tech Lead Typesafe – Reactive apps on the JVM. twitter: @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.
