Debug missing messages in akka
I have the following architecture at the moment:
Load(Play app with basic interface for load tests) -> Gateway(Spray
application with REST interface for incoming messages) -> Processor(akka
app that works with MongoDB) -> MongoDB
Everything works fine as long as number of messages I am pushing through
is low. However when I try to push 10000 events, that will eventully end
up at MongoDB as documents, it stops at random places, for example on 742
message or 982 message and does nothing after.
What would be the best way to debug such situations? On the load side I am
just pushing hard into the REST service:
for (i © 0 until users) workerRouter ! Load(server, i)
and then in the workerRouter
WS.url(server + "/track/message").post(Json.toJson(newUser)).map {
response =>
println(response.body)
true
}
On the spray side:
pathPrefix("track") {
path("message") {
post {
entity(as[TrackObj]) { msg =>
processors ! msg
complete("")
}
}
}
}
On the processor side it's just basically an insert into a collection. Any
suggestions on wher eto start from?
No comments:
Post a Comment