{"action":"created","issue":{"url":"https://api.github.com/repos/typesafehub/akka-contrib-extra/issues/24","labels_url":"https://api.github.com/repos/typesafehub/akka-contrib-extra/issues/24/labels{/name}","comments_url":"https://api.github.com/repos/typesafehub/akka-contrib-extra/issues/24/comments","events_url":"https://api.github.com/repos/typesafehub/akka-contrib-extra/issues/24/events","html_url":"https://github.com/typesafehub/akka-contrib-extra/issues/24","id":63941812,"number":24,"title":"InputStreamPublisher blocks such that it may not be shutdown","user":{"login":"huntc","id":694893,"avatar_url":"https://avatars.githubusercontent.com/u/694893?v=3","gravatar_id":"","url":"https://api.github.com/users/huntc","html_url":"https://github.com/huntc","followers_url":"https://api.github.com/users/huntc/followers","following_url":"https://api.github.com/users/huntc/following{/other_user}","gists_url":"https://api.github.com/users/huntc/gists{/gist_id}","starred_url":"https://api.github.com/users/huntc/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/huntc/subscriptions","organizations_url":"https://api.github.com/users/huntc/orgs","repos_url":"https://api.github.com/users/huntc/repos","events_url":"https://api.github.com/users/huntc/events{/privacy}","received_events_url":"https://api.github.com/users/huntc/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":10,"created_at":"2015-03-24T08:56:34Z","updated_at":"2015-03-24T09:54:33Z","closed_at":null,"body":"`InputStreamPublisher` blocks its actor thread when reading from a stream. This causes a problem when the actor system is shutdown as the publisher will never receive its stop message.\r\n\r\nThe following JVM dump illustrates the thread being blocked. The dump was taken once `system.shutdown()` and then `system.awaitTermination()` had been called.\r\n\r\n```\r\n\"conductr-akka.actor.default-dispatcher-15\" #24 prio=5 os_prio=31 tid=0x00007fddb1af8000 nid=0x6503 runnable [0x0000000115cb1000]\r\n   java.lang.Thread.State: RUNNABLE\r\n\tat java.io.FileInputStream.readBytes(Native Method)\r\n\tat java.io.FileInputStream.read(FileInputStream.java:234)\r\n\tat java.io.BufferedInputStream.read1(BufferedInputStream.java:284)\r\n\tat java.io.BufferedInputStream.read(BufferedInputStream.java:345)\r\n\t- locked <0x00000007b84491b8> (a java.lang.UNIXProcess$ProcessPipeInputStream)\r\n\tat java.io.FilterInputStream.read(FilterInputStream.java:107)\r\n\tat akka.contrib.stream.InputStreamPublisher$$anonfun$1.apply$mcI$sp(InputStreamPublisher.scala:66)\r\n\tat akka.contrib.stream.InputStreamPublisher$$anonfun$1.apply(InputStreamPublisher.scala:66)\r\n\tat akka.contrib.stream.InputStreamPublisher$$anonfun$1.apply(InputStreamPublisher.scala:66)\r\n\tat akka.dispatch.MonitorableThreadFactory$AkkaForkJoinWorkerThread$$anon$3.block(ThreadPoolBuilder.scala:169)\r\n\tat scala.concurrent.forkjoin.ForkJoinPool.managedBlock(ForkJoinPool.java:3640)\r\n\tat akka.dispatch.MonitorableThreadFactory$AkkaForkJoinWorkerThread.blockOn(ThreadPoolBuilder.scala:167)\r\n\tat scala.concurrent.package$.blocking(package.scala:123)\r\n\tat akka.contrib.stream.InputStreamPublisher.read(InputStreamPublisher.scala:66)\r\n```"},"comment":{"url":"https://api.github.com/repos/typesafehub/akka-contrib-extra/issues/comments/85427804","html_url":"https://github.com/typesafehub/akka-contrib-extra/issues/24#issuecomment-85427804","issue_url":"https://api.github.com/repos/typesafehub/akka-contrib-extra/issues/24","id":85427804,"user":{"login":"viktorklang","id":10871,"avatar_url":"https://avatars.githubusercontent.com/u/10871?v=3","gravatar_id":"","url":"https://api.github.com/users/viktorklang","html_url":"https://github.com/viktorklang","followers_url":"https://api.github.com/users/viktorklang/followers","following_url":"https://api.github.com/users/viktorklang/following{/other_user}","gists_url":"https://api.github.com/users/viktorklang/gists{/gist_id}","starred_url":"https://api.github.com/users/viktorklang/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/viktorklang/subscriptions","organizations_url":"https://api.github.com/users/viktorklang/orgs","repos_url":"https://api.github.com/users/viktorklang/repos","events_url":"https://api.github.com/users/viktorklang/events{/privacy}","received_events_url":"https://api.github.com/users/viktorklang/received_events","type":"User","site_admin":false},"created_at":"2015-03-24T09:54:33Z","updated_at":"2015-03-24T09:54:33Z","body":"`…ProviderFactoryBeanServiceVisitor`"}}