The attached is the log. On Wed, Jul 27, 2016 at 9:50 AM, Guofeng Zhang <[email protected]> wrote:
> Hi, > > I tried a sample to use range request in an ActorPublisher to download a > large file. But only one range is downloaded. The publisher is stopped when > another range request is downloading data. > > I set akka logger to "DEBUG". I also printed messages when received > messages in the publisher, but I still cannot know who stopped the > publisher. > > This is the source code (very short) > > > https://github.com/guofengzh/AkkaStreamsChunkedDownloader/blob/master/src/main/scala/com/jasonmartens/s3downloader/ChunkPublisher.scala > > This is the output: > > chunkList: List(RequestChunk(1,0,1024), RequestChunk(2,1024,1024), > RequestChunk(3,2048,1024), RequestChunk(4,3072,120)) > Request > requestChunks > requesting chunks: totalDemand: 16, inFlightDemand: 0 > Downloading chunk 1 > ChunkDownloaded > chunkComplete: 1:true > ChunkData > chunkData 1 succeeded > emitChunks - Active: true > emitting chunk 1 > requestChunks > requesting chunks: totalDemand: 15, inFlightDemand: 0 > Downloading chunk 2 > Stopped > Got 1024 bytes > [ERROR] [07/27/2016 09:37:30.508] > [default-akka.actor.default-dispatcher-9] > [akka.actor.ActorSystemImpl(default)] Outgoing request stream error > (akka.stream.AbruptTerminationException) > > Is the publisher implemented incorrectly and has been timed out? > > Your help is appreciated. > > Thanks > > Guofeng > > > > -- >>>>>>>>>> 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 https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[DEBUG] [07/27/2016 23:37:35.272] [main] [EventStream(akka://default)] logger log1-Logging$DefaultLogger started [DEBUG] [07/27/2016 23:37:35.273] [main] [EventStream(akka://default)] Default Loggers started [DEBUG] [07/27/2016 23:37:35.282] [default-akka.actor.default-dispatcher-5] [akka://default/system] now supervising Actor[akka://default/system/deadLetterListener#1036362911] [DEBUG] [07/27/2016 23:37:35.283] [default-akka.actor.default-dispatcher-3] [akka://default/system] now supervising Actor[akka://default/system/eventStreamUnsubscriber-1#-2098487343] [DEBUG] [07/27/2016 23:37:35.285] [default-akka.actor.default-dispatcher-5] [akka://default/system/deadLetterListener] started (akka.event.DeadLetterListener@70f094a9) [DEBUG] [07/27/2016 23:37:35.289] [default-akka.actor.default-dispatcher-3] [akka://default/system/eventStreamUnsubscriber-1] started (akka.event.EventStreamUnsubscriber@2223354) [DEBUG] [07/27/2016 23:37:35.292] [default-akka.actor.default-dispatcher-2] [akka://default/system/deadLetterListener] now watched by Actor[akka://default/system/eventStreamUnsubscriber-1#-2098487343] [DEBUG] [07/27/2016 23:37:35.335] [default-akka.actor.default-dispatcher-4] [akka://default/system/log1-Logging$DefaultLogger] now watched by Actor[akka://default/system/eventStreamUnsubscriber-1#-2098487343] [DEBUG] [07/27/2016 23:37:35.356] [default-akka.actor.default-dispatcher-7] [akka://default/user] now supervising Actor[akka://default/user/StreamSupervisor-0#-1668013615] [DEBUG] [07/27/2016 23:37:35.357] [default-akka.actor.default-dispatcher-4] [akka://default/user/StreamSupervisor-0] started (akka.stream.impl.StreamSupervisor@7749849) chunkList: List(RequestChunk(1,0,1024), RequestChunk(2,1024,1024), RequestChunk(3,2048,1024), RequestChunk(4,3072,120)) [DEBUG] [07/27/2016 23:37:35.803] [default-akka.actor.default-dispatcher-7] [akka://default/user/StreamSupervisor-0] now supervising Actor[akka://default/user/StreamSupervisor-0/flow-0-0-unknown-operation#1690571858] [DEBUG] [07/27/2016 23:37:35.809] [default-akka.actor.default-dispatcher-6] [akka://default/user/StreamSupervisor-0] now supervising Actor[akka://default/user/StreamSupervisor-0/flow-0-1-actorPublisherSource#2038215895] [DEBUG] [07/27/2016 23:37:35.823] [default-akka.actor.default-dispatcher-3] [akka://default/user] now supervising Actor[akka://default/user/StreamSupervisor-1#-791387240] [DEBUG] [07/27/2016 23:37:35.823] [default-akka.actor.default-dispatcher-3] [akka://default/user/StreamSupervisor-1] started (akka.stream.impl.StreamSupervisor@480b3a46) [DEBUG] [07/27/2016 23:37:35.824] [default-akka.actor.default-dispatcher-6] [akka://default/user/StreamSupervisor-0/flow-0-1-actorPublisherSource] started (com.jasonmartens.s3downloader.ChunkPublisher@5133d9ba) [DEBUG] [07/27/2016 23:37:35.832] [default-akka.actor.default-dispatcher-7] [akka://default/user/StreamSupervisor-0/flow-0-0-unknown-operation] started (akka.stream.impl.fusing.ActorGraphInterpreter@1f8d63ed) Request requestChunks requesting chunks: totalDemand: 16, inFlightDemand: 0 [DEBUG] [07/27/2016 23:37:36.147] [default-akka.actor.default-dispatcher-7] [AkkaSSLConfig(akka://default)] Initializing AkkaSSLConfig extension... [DEBUG] [07/27/2016 23:37:36.149] [default-akka.actor.default-dispatcher-7] [AkkaSSLConfig(akka://default)] buildHostnameVerifier: created hostname verifier: com.typesafe.sslconfig.ssl.DefaultHostnameVerifier@31b1fcb0 [DEBUG] [07/27/2016 23:37:37.073] [default-akka.actor.default-dispatcher-8] [akka://default/user] now supervising Actor[akka://default/user/pool-master#-1898681296] [DEBUG] [07/27/2016 23:37:37.074] [default-akka.actor.default-dispatcher-3] [akka://default/user/StreamSupervisor-2] started (akka.stream.impl.StreamSupervisor@604d9400) [DEBUG] [07/27/2016 23:37:37.074] [default-akka.actor.default-dispatcher-8] [akka://default/user] now supervising Actor[akka://default/user/StreamSupervisor-2#1673241966] [DEBUG] [07/27/2016 23:37:37.074] [default-akka.actor.default-dispatcher-4] [akka://default/user/pool-master] started (akka.http.impl.engine.client.PoolMasterActor@35e42517) Downloading chunk 1 [DEBUG] [07/27/2016 23:37:37.099] [default-akka.actor.default-dispatcher-2] [akka://default/user/pool-master] now supervising Actor[akka://default/user/pool-master/PoolInterfaceActor-0#-1418993786] [DEBUG] [07/27/2016 23:37:37.103] [default-akka.actor.default-dispatcher-7] [akka://default/user/pool-master/PoolInterfaceActor-0] (Re-)starting host connection pool to runner.dressbad.com:80 [DEBUG] [07/27/2016 23:37:37.227] [default-akka.actor.default-dispatcher-2] [akka://default/user] now supervising Actor[akka://default/user/StreamSupervisor-3#-206330492] [DEBUG] [07/27/2016 23:37:37.227] [default-akka.actor.default-dispatcher-2] [akka://default/user/StreamSupervisor-3] started (akka.stream.impl.StreamSupervisor@10c801c3) [DEBUG] [07/27/2016 23:37:37.242] [default-akka.actor.default-dispatcher-2] [akka://default/system] now supervising Actor[akka://default/system/IO-TCP#-1283237717] [DEBUG] [07/27/2016 23:37:37.258] [default-akka.actor.default-dispatcher-3] [akka://default/system/IO-TCP] started (akka.io.TcpManager@328a5b7a) [DEBUG] [07/27/2016 23:37:37.258] [default-akka.actor.default-dispatcher-3] [akka://default/system/IO-TCP] now supervising Actor[akka://default/system/IO-TCP/selectors#1896739176] [DEBUG] [07/27/2016 23:37:37.261] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-TCP/selectors] started (akka.routing.RouterPoolActor@4b53033d) [DEBUG] [07/27/2016 23:37:37.262] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-TCP/selectors] now supervising Actor[akka://default/system/IO-TCP/selectors/$a#912248128] [DEBUG] [07/27/2016 23:37:37.297] [default-akka.actor.default-dispatcher-8] [akka://default/system/IO-TCP/selectors/$a] started (akka.io.SelectionHandler@51b92641) [DEBUG] [07/27/2016 23:37:37.297] [default-akka.actor.default-dispatcher-8] [akka://default/system/IO-TCP/selectors/$a] now watched by Actor[akka://default/system/IO-TCP/selectors#1896739176] [DEBUG] [07/27/2016 23:37:37.327] [default-akka.actor.default-dispatcher-4] [akka://default/user] now supervising Actor[akka://default/user/SlotProcessor-1#-322884574] [DEBUG] [07/27/2016 23:37:37.343] [default-akka.actor.default-dispatcher-8] [akka://default/user/SlotProcessor-1] started (akka.http.impl.engine.client.PoolSlot$SlotProcessor@5c4c2489) [DEBUG] [07/27/2016 23:37:37.393] [default-akka.actor.default-dispatcher-8] [akka://default/user/StreamSupervisor-2] now supervising Actor[akka://default/user/StreamSupervisor-2/flow-1-2-unknown-operation#1247596755] [DEBUG] [07/27/2016 23:37:37.401] [default-akka.actor.default-dispatcher-7] [akka://default/user/pool-master/PoolInterfaceActor-0] started (akka.http.impl.engine.client.PoolInterfaceActor@30421cd5) [DEBUG] [07/27/2016 23:37:37.401] [default-akka.actor.default-dispatcher-7] [akka://default/user/pool-master/PoolInterfaceActor-0] now watched by Actor[akka://default/user/pool-master#-1898681296] [DEBUG] [07/27/2016 23:37:37.403] [default-akka.actor.default-dispatcher-7] [akka://default/user] now supervising Actor[akka://default/user/SlotProcessor-3#-150368189] [DEBUG] [07/27/2016 23:37:37.403] [default-akka.actor.default-dispatcher-7] [akka://default/user] now supervising Actor[akka://default/user/SlotProcessor-2#1126447419] [DEBUG] [07/27/2016 23:37:37.403] [default-akka.actor.default-dispatcher-7] [akka://default/user] now supervising Actor[akka://default/user/SlotProcessor-0#1432701514] [DEBUG] [07/27/2016 23:37:37.404] [default-akka.actor.default-dispatcher-7] [akka://default/user/SlotProcessor-3] started (akka.http.impl.engine.client.PoolSlot$SlotProcessor@2c044af0) [DEBUG] [07/27/2016 23:37:37.406] [default-akka.actor.default-dispatcher-2] [akka://default/user/SlotProcessor-2] started (akka.http.impl.engine.client.PoolSlot$SlotProcessor@637639c5) [DEBUG] [07/27/2016 23:37:37.409] [default-akka.actor.default-dispatcher-8] [akka://default/user/SlotProcessor-1] become unconnected, from subscriber pending [DEBUG] [07/27/2016 23:37:37.409] [default-akka.actor.default-dispatcher-7] [akka://default/user/SlotProcessor-3] become unconnected, from subscriber pending [DEBUG] [07/27/2016 23:37:37.411] [default-akka.actor.default-dispatcher-3] [akka://default/user/SlotProcessor-0] started (akka.http.impl.engine.client.PoolSlot$SlotProcessor@85d6ee8) [DEBUG] [07/27/2016 23:37:37.411] [default-akka.actor.default-dispatcher-2] [akka://default/user/SlotProcessor-2] become unconnected, from subscriber pending [DEBUG] [07/27/2016 23:37:37.411] [default-akka.actor.default-dispatcher-3] [akka://default/user/SlotProcessor-0] become unconnected, from subscriber pending [DEBUG] [07/27/2016 23:37:37.414] [default-akka.actor.default-dispatcher-4] [akka://default/user/StreamSupervisor-2/flow-1-2-unknown-operation] started (akka.stream.impl.fusing.ActorGraphInterpreter@1d038d) [DEBUG] [07/27/2016 23:37:37.513] [default-akka.actor.default-dispatcher-5] [akka://default/user/StreamSupervisor-2] now supervising Actor[akka://default/user/StreamSupervisor-2/flow-2-0-unknown-operation#1431277784] [DEBUG] [07/27/2016 23:37:37.518] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-TCP] now watched by Actor[akka://default/user/StreamSupervisor-2/$$a#1008808303] [DEBUG] [07/27/2016 23:37:37.524] [default-akka.actor.default-dispatcher-5] [akka://default/user/StreamSupervisor-2/flow-2-0-unknown-operation] started (akka.stream.impl.fusing.ActorGraphInterpreter@78365857) [DEBUG] [07/27/2016 23:37:37.544] [default-akka.actor.default-dispatcher-5] [akka://default/user/StreamSupervisor-2] now supervising Actor[akka://default/user/StreamSupervisor-2/flow-2-1-SlotProcessorInternalConnectionFlow-actorPublisherSource#628686351] [DEBUG] [07/27/2016 23:37:37.545] [default-akka.actor.default-dispatcher-5] [akka://default/user/StreamSupervisor-2/flow-2-1-SlotProcessorInternalConnectionFlow-actorPublisherSource] started (akka.http.impl.engine.client.PoolSlot$FlowInportActor@55f3a027) [DEBUG] [07/27/2016 23:37:37.552] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-TCP/selectors/$a] now supervising Actor[akka://default/system/IO-TCP/selectors/$a/0#-340525593] [DEBUG] [07/27/2016 23:37:37.555] [default-akka.actor.default-dispatcher-7] [akka://default/user/StreamSupervisor-2] now supervising Actor[akka://default/user/StreamSupervisor-2/flow-2-2-SlotProcessorInternalConnectionFlow-actorSubscriberSink#-1664819009] [DEBUG] [07/27/2016 23:37:37.556] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/0] started (akka.io.TcpOutgoingConnection@5b1c7314) [DEBUG] [07/27/2016 23:37:37.556] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/0] now watched by Actor[akka://default/system/IO-TCP/selectors/$a#912248128] [DEBUG] [07/27/2016 23:37:37.560] [default-akka.actor.default-dispatcher-7] [akka://default/user/StreamSupervisor-2/flow-2-2-SlotProcessorInternalConnectionFlow-actorSubscriberSink] started (akka.http.impl.engine.client.PoolSlot$FlowOutportActor@16b655c3) [DEBUG] [07/27/2016 23:37:37.564] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/0] Resolving runner.dressbad.com before connecting [DEBUG] [07/27/2016 23:37:37.618] [default-akka.actor.default-dispatcher-8] [akka://default/system] now supervising Actor[akka://default/system/IO-DNS#2213883] [DEBUG] [07/27/2016 23:37:37.629] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$a] started (akka.io.InetAddressDnsResolver@415d6aa0) [DEBUG] [07/27/2016 23:37:37.629] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$a] now watched by Actor[akka://default/system/IO-DNS/inet-address#-1633219192] [DEBUG] [07/27/2016 23:37:37.630] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$b] started (akka.io.InetAddressDnsResolver@7edaa008) [DEBUG] [07/27/2016 23:37:37.630] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$b] now watched by Actor[akka://default/system/IO-DNS/inet-address#-1633219192] [DEBUG] [07/27/2016 23:37:37.630] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$c] started (akka.io.InetAddressDnsResolver@19462c0f) [DEBUG] [07/27/2016 23:37:37.630] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$c] now watched by Actor[akka://default/system/IO-DNS/inet-address#-1633219192] [DEBUG] [07/27/2016 23:37:37.631] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$d] started (akka.io.InetAddressDnsResolver@7a658f78) [DEBUG] [07/27/2016 23:37:37.631] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address/$d] now watched by Actor[akka://default/system/IO-DNS/inet-address#-1633219192] [DEBUG] [07/27/2016 23:37:37.631] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address] started (akka.routing.RouterPoolActor@50c7e2fe) [DEBUG] [07/27/2016 23:37:37.631] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address] now supervising Actor[akka://default/system/IO-DNS/inet-address/$a#1964409499] [DEBUG] [07/27/2016 23:37:37.631] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address] now supervising Actor[akka://default/system/IO-DNS/inet-address/$b#660549898] [DEBUG] [07/27/2016 23:37:37.631] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address] now supervising Actor[akka://default/system/IO-DNS/inet-address/$c#102628079] [DEBUG] [07/27/2016 23:37:37.631] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS/inet-address] now supervising Actor[akka://default/system/IO-DNS/inet-address/$d#237290563] [DEBUG] [07/27/2016 23:37:37.634] [default-akka.actor.default-dispatcher-8] [akka://default/system/IO-DNS] started (akka.io.SimpleDnsManager@339f23bb) [DEBUG] [07/27/2016 23:37:37.635] [default-akka.actor.default-dispatcher-8] [akka://default/system/IO-DNS] now supervising Actor[akka://default/system/IO-DNS/inet-address#-1633219192] [DEBUG] [07/27/2016 23:37:37.643] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-DNS] Resolution request for runner.dressbad.com from Actor[akka://default/system/IO-TCP/selectors/$a/0#-340525593] [DEBUG] [07/27/2016 23:37:37.665] [default-akka.actor.default-dispatcher-5] [akka://default/system/IO-TCP/selectors/$a/0] Attempting connection to [runner.dressbad.com/67.215.230.109:80] [DEBUG] [07/27/2016 23:37:41.285] [default-akka.actor.default-dispatcher-13] [akka://default/system/IO-TCP/selectors/$a/0] Connection established to [runner.dressbad.com:80] [DEBUG] [07/27/2016 23:37:41.301] [default-akka.actor.default-dispatcher-11] [akka://default/system/IO-TCP/selectors/$a/0] now watched by Actor[akka://default/user/StreamSupervisor-2/$$a#1008808303] [DEBUG] [07/27/2016 23:37:41.306] [default-akka.actor.default-dispatcher-13] [akka://default/system/IO-TCP] no longer watched by Actor[akka://default/user/StreamSupervisor-2/$$a#1008808303] ChunkDownloaded chunkComplete: 1:true [DEBUG] [07/27/2016 23:37:51.018] [default-akka.actor.default-dispatcher-12] [akka://default/user/StreamSupervisor-1] now supervising Actor[akka://default/user/StreamSupervisor-1/flow-4-0-unknown-operation#-1991683378] [DEBUG] [07/27/2016 23:37:51.019] [default-akka.actor.default-dispatcher-10] [akka://default/user/StreamSupervisor-1/flow-4-0-unknown-operation] started (akka.stream.impl.fusing.ActorGraphInterpreter@73a2d376) [DEBUG] [07/27/2016 23:37:53.398] [default-akka.actor.default-dispatcher-8] [akka://default/user/SlotProcessor-0] Slot 0 disconnected after regular connection close ChunkData chunkData 1 succeeded emitChunks - Active: true emitting chunk 1 requestChunks requesting chunks: totalDemand: 15, inFlightDemand: 0 Downloading chunk 2 Got 1024 bytes Stopped [DEBUG] [07/27/2016 23:37:53.436] [default-akka.actor.default-dispatcher-10] [akka://default/user/StreamSupervisor-2/flow-2-1-SlotProcessorInternalConnectionFlow-actorPublisherSource] stopped [DEBUG] [07/27/2016 23:37:53.443] [default-akka.actor.default-dispatcher-2] [akka://default/user/StreamSupervisor-1/flow-4-0-unknown-operation] stopped [DEBUG] [07/27/2016 23:37:53.444] [default-akka.actor.default-dispatcher-3] [akka://default/user/StreamSupervisor-0/flow-0-1-actorPublisherSource] stopped [DEBUG] [07/27/2016 23:37:53.444] [default-akka.actor.default-dispatcher-15] [akka://default/user/StreamSupervisor-0/flow-0-0-unknown-operation] stopped [DEBUG] [07/27/2016 23:37:53.449] [default-akka.actor.default-dispatcher-13] [akka://default/user/StreamSupervisor-2/flow-2-2-SlotProcessorInternalConnectionFlow-actorSubscriberSink] stopped [DEBUG] [07/27/2016 23:37:53.452] [default-akka.actor.default-dispatcher-8] [akka://default/user/StreamSupervisor-2] now supervising Actor[akka://default/user/StreamSupervisor-2/flow-5-0-unknown-operation#2022451510] [DEBUG] [07/27/2016 23:37:53.452] [default-akka.actor.default-dispatcher-8] [akka://default/user/StreamSupervisor-2] now supervising Actor[akka://default/user/StreamSupervisor-2/flow-5-1-SlotProcessorInternalConnectionFlow-actorPublisherSource#-836276752] [DEBUG] [07/27/2016 23:37:53.452] [default-akka.actor.default-dispatcher-8] [akka://default/user/StreamSupervisor-2] now supervising Actor[akka://default/user/StreamSupervisor-2/flow-5-2-SlotProcessorInternalConnectionFlow-actorSubscriberSink#1712916894] [DEBUG] [07/27/2016 23:37:53.453] [default-akka.actor.default-dispatcher-12] [akka://default/system/IO-TCP/selectors/$a/0] stopped [DEBUG] [07/27/2016 23:37:53.457] [default-akka.actor.default-dispatcher-12] [akka://default/system/IO-TCP/selectors/$a] received AutoReceiveMessage Envelope(Terminated(Actor[akka://default/system/IO-TCP/selectors/$a/0#-340525593]),Actor[akka://default/system/IO-TCP/selectors/$a/0#-340525593]) [DEBUG] [07/27/2016 23:37:53.457] [default-akka.actor.default-dispatcher-12] [akka://default/system/IO-TCP] now watched by Actor[akka://default/user/StreamSupervisor-2/$$b#-1126402444] [DEBUG] [07/27/2016 23:37:53.457] [default-akka.actor.default-dispatcher-12] [akka://default/user/StreamSupervisor-2/flow-5-1-SlotProcessorInternalConnectionFlow-actorPublisherSource] started (akka.http.impl.engine.client.PoolSlot$FlowInportActor@58bcdad6) [DEBUG] [07/27/2016 23:37:53.457] [default-akka.actor.default-dispatcher-12] [akka://default/user/StreamSupervisor-2/flow-5-2-SlotProcessorInternalConnectionFlow-actorSubscriberSink] started (akka.http.impl.engine.client.PoolSlot$FlowOutportActor@572e7493) [DEBUG] [07/27/2016 23:37:53.459] [default-akka.actor.default-dispatcher-4] [akka://default/user] stopping [DEBUG] [07/27/2016 23:37:53.460] [default-akka.actor.default-dispatcher-4] [akka://default/user/SlotProcessor-0] stopped [DEBUG] [07/27/2016 23:37:53.460] [default-akka.actor.default-dispatcher-12] [akka://default/system/IO-TCP/selectors/$a] now supervising Actor[akka://default/system/IO-TCP/selectors/$a/1#-757103088] [DEBUG] [07/27/2016 23:37:53.460] [default-akka.actor.default-dispatcher-4] [akka://default/user/SlotProcessor-1] stopped [DEBUG] [07/27/2016 23:37:53.460] [default-akka.actor.default-dispatcher-12] [akka://default/system/IO-TCP/selectors/$a/1] started (akka.io.TcpOutgoingConnection@69c220a0) [DEBUG] [07/27/2016 23:37:53.460] [default-akka.actor.default-dispatcher-12] [akka://default/system/IO-TCP/selectors/$a/1] now watched by Actor[akka://default/system/IO-TCP/selectors/$a#912248128] [DEBUG] [07/27/2016 23:37:53.462] [default-akka.actor.default-dispatcher-4] [akka://default/user/SlotProcessor-2] stopped [DEBUG] [07/27/2016 23:37:53.462] [default-akka.actor.default-dispatcher-2] [akka://default/user/StreamSupervisor-2/flow-5-0-unknown-operation] started (akka.stream.impl.fusing.ActorGraphInterpreter@654c9765) [DEBUG] [07/27/2016 23:37:53.462] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-TCP/selectors/$a/1] Resolving runner.dressbad.com before connecting [DEBUG] [07/27/2016 23:37:53.462] [default-akka.actor.default-dispatcher-2] [akka://default/system/IO-TCP/selectors/$a/1] Attempting connection to [runner.dressbad.com/67.215.230.109:80] [DEBUG] [07/27/2016 23:37:53.463] [default-akka.actor.default-dispatcher-5] [akka://default/user/StreamSupervisor-0] stopped [DEBUG] [07/27/2016 23:37:53.463] [default-akka.actor.default-dispatcher-10] [akka://default/user/StreamSupervisor-1] stopped [DEBUG] [07/27/2016 23:37:53.463] [default-akka.actor.default-dispatcher-10] [akka://default/user/StreamSupervisor-3] stopped [DEBUG] [07/27/2016 23:37:53.463] [default-akka.actor.default-dispatcher-10] [akka://default/user/pool-master] stopping [DEBUG] [07/27/2016 23:37:53.463] [default-akka.actor.default-dispatcher-16] [akka://default/user/StreamSupervisor-2] stopping [DEBUG] [07/27/2016 23:37:53.463] [default-akka.actor.default-dispatcher-10] [akka://default/user/pool-master/PoolInterfaceActor-0] no longer watched by Actor[akka://default/user/pool-master#-1898681296] [DEBUG] [07/27/2016 23:37:53.463] [default-akka.actor.default-dispatcher-10] [akka://default/user/pool-master/PoolInterfaceActor-0] stopped [DEBUG] [07/27/2016 23:37:53.464] [default-akka.actor.default-dispatcher-6] [akka://default/user/StreamSupervisor-2/flow-5-2-SlotProcessorInternalConnectionFlow-actorSubscriberSink] stopped [DEBUG] [07/27/2016 23:37:53.465] [default-akka.actor.default-dispatcher-5] [akka://default/user/pool-master] stopped [DEBUG] [07/27/2016 23:37:53.466] [default-akka.actor.default-dispatcher-8] [akka://default/user/StreamSupervisor-2/flow-2-0-unknown-operation] stopped [DEBUG] [07/27/2016 23:37:53.466] [default-akka.actor.default-dispatcher-12] [akka://default/user/SlotProcessor-3] stopped [DEBUG] [07/27/2016 23:37:53.470] [default-akka.actor.default-dispatcher-10] [akka://default/user/StreamSupervisor-2/flow-1-2-unknown-operation] stopped [DEBUG] [07/27/2016 23:37:53.471] [default-akka.actor.default-dispatcher-7] [akka://default/user/StreamSupervisor-2/flow-5-1-SlotProcessorInternalConnectionFlow-actorPublisherSource] stopped [INFO] [07/27/2016 23:37:53.471] [default-akka.actor.default-dispatcher-7] [akka://default/user/SlotProcessor-0] Message [akka.http.impl.engine.client.PoolSlot$FromConnection] from Actor[akka://default/user/StreamSupervisor-2/flow-5-1-SlotProcessorInternalConnectionFlow-actorPublisherSource#-836276752] to Actor[akka://default/user/SlotProcessor-0#1432701514] 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'. [ERROR] [07/27/2016 23:37:53.471] [default-akka.actor.default-dispatcher-16] [akka.actor.ActorSystemImpl(default)] Outgoing request stream error (akka.stream.AbruptTerminationException) [DEBUG] [07/27/2016 23:37:53.473] [default-akka.actor.default-dispatcher-16] [akka://default/user/StreamSupervisor-2/flow-5-0-unknown-operation] stopped [DEBUG] [07/27/2016 23:37:53.473] [default-akka.actor.default-dispatcher-7] [akka://default/system/IO-TCP/selectors/$a/1] received AutoReceiveMessage Envelope(Terminated(Actor[akka://default/user/StreamSupervisor-2/$$b#-1126402444]),Actor[akka://default/user/StreamSupervisor-2/$$b#-1126402444]) [DEBUG] [07/27/2016 23:37:53.473] [default-akka.actor.default-dispatcher-16] [akka://default/system/IO-TCP] no longer watched by Actor[akka://default/user/StreamSupervisor-2/$$b#-1126402444] [DEBUG] [07/27/2016 23:37:53.473] [default-akka.actor.default-dispatcher-16] [akka://default/user/StreamSupervisor-2] stopped [DEBUG] [07/27/2016 23:37:53.477] [default-akka.actor.default-dispatcher-16] [akka://default/user] stopped [DEBUG] [07/27/2016 23:37:53.480] [default-akka.actor.default-dispatcher-16] [akka://default/system] received AutoReceiveMessage Envelope(Terminated(Actor[akka://default/user]),Actor[akka://default/user]) [DEBUG] [07/27/2016 23:37:53.483] [default-akka.actor.default-dispatcher-16] [EventStream] shutting down: StandardOutLogger started [DEBUG] [07/27/2016 23:37:53.484] [default-akka.actor.default-dispatcher-7] [akka://default/system/IO-TCP/selectors/$a/1] Monitored actor [Actor[akka://default/user/StreamSupervisor-2/$$b#-1126402444]] terminated [DEBUG] [07/27/2016 23:37:53.485] [default-akka.actor.default-dispatcher-7] [akka://default/system/IO-TCP/selectors/$a/1] stopped [DEBUG] [07/27/2016 23:37:53.486] [default-akka.actor.default-dispatcher-7] [akka://default/system/IO-TCP/selectors/$a] received AutoReceiveMessage Envelope(Terminated(Actor[akka://default/system/IO-TCP/selectors/$a/1#-757103088]),Actor[akka://default/system/IO-TCP/selectors/$a/1#-757103088])
