I have created this bot to prank my friends, and study some Akka in the process. But I am having a problem that I am unable to solve, so I was hoping someone might have a clue.
The code is at https://github.com/nlw0/hackfm . What it does is to enter a page that has a simple pool, fetch current results, then vote on a certain entry so it stays as the first place. Such fun! The program consists of three actors. The frist is `WebpageRequester`, which receives periodically a `RequestWebpage` message to signal a new iteration. It starts the fetching of a webpage via akka-http, and the result is sent via `pipeTo` to a `WebpageProcessor` actor. `WebpageProcessor` parses the requested webpage, then processes the data, and decides how many new votes must be cast. This command is sent to another actor, a `FuncmesVoter`, which performs one http POST request for each vote. Now what is happening is that the system works fine at first. It performs all the necessary requests, and the logic is perfect. The iterations are scheduled to happen every 10 seconds. But then after a couple of hours up and running, it appears something near the first http request stops working. Like the first http request flow is created, but they never completes. And I don't get any kind of error messages. I am even waiting for `Status.Failure` at the processor, but nothing arrives. The logs only show the messages of the beginning of new iterations. And if I stop and restart the program, it's back to normal. So, something between the first http request and the second actor receiving the future response is breaking silently... How do I even debug this? I was upset, because that is not a very robust system... Even if I did something wrong, there should be a way to diagnose it. Or it could be some nasty bug... I tried to replicate the problem with a simpler program, fetching and parsing a news site periodically, but I was unable to do it, in that case it worked perfectly. Any help is appreciated... Also any suggestions of how to change the architecture. Maybe this stream creation with the result piped to an actor was not a good choice? Thanks, ++nic -- >>>>>>>>>> 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.
