[akka-user] Re: Unordered merge of 2..n streams created by groupBy

2015-01-08 Thread Tim Harper
Akka maintainers, how does this solution look (see mentioned gist in quoted text)? I'll probably need some degree of guidance, but this solution is working well for my needs; I'm happy to produce a pull-request for Akka streams to implement FlattenStrategy.mergeUnordered. On Wednesday, January

[akka-user] Re: File based mailbox - Files under _mb location grows large consistently without getting cleared

2015-01-08 Thread aramankandath
I could see a similar issue was discussed in the below thread from Daniele. https://groups.google.com/forum/#!searchin/akka-user/file$20based/akka-user/0Yt78n73a4o But, I couldn't find an answer there for the files growing big issue. On Friday, January 9, 2015 at 11:56:39 AM UTC+5:30,

[akka-user] File based mailbox - Files under _mb location grows large consistently without getting cleared

2015-01-08 Thread aramankandath
Hi Akka Users, I have a problem with actors using the file based mailbox. The size of mailbox files under _mb folder keeps on increasing as the number of messages are processed. All messages are getting processed fine in the system, so shouldn't they be removed from the file when completed? I

Re: [akka-user] Re: File based mailbox - Files under _mb location grows large consistently without getting cleared

2015-01-08 Thread Jonas Bonér
Durable MBs are no longer supported. I recommend you to switch to Akka Persistence (perhaps with the LevelDB Journal, since it is closest to your durable MB). Is that possible? On Fri, Jan 9, 2015 at 7:27 AM, aramankand...@gmail.com wrote: I could see a similar issue was discussed in the below

Re: [akka-user] akka.actor.ActorNotFound In Spark Streaming on Mesos (using ssc.actorStream)

2015-01-08 Thread Patrik Nordwall
If the actor system name has changed to sparkExecutor the actor selection using sparkDriver is not valid any more. What happens if you change the actor selection path? /Patrik On Wed, Jan 7, 2015 at 2:52 PM, Christophe Billiard christophe.billi...@gmail.com wrote: Hi all, I have an

Re: [akka-user] Akka Persistence on the Query Side: The Conclusion

2015-01-08 Thread Jonas Bonér
That is a great point Greg. On Wed, Jan 7, 2015 at 10:15 PM, Greg Young gregoryyou...@gmail.com wrote: The consistency of the query model should be achieved as soon as possible and close to real-time. It really depends on the domain. I have worked in many situations where the data in

[akka-user] Re: Akka Http Client - User-Agent header

2015-01-08 Thread André
Hi Marcin, the user agent string is a config property and configured here https://github.com/akka/akka/blob/release-2.3-dev/akka-http-core/src/main/resources/reference.conf#L69-L73 . Cheers André On Wednesday, January 7, 2015 9:14:23 PM UTC+1, Marcin Gosk wrote: Hey guys, is it possible to

[akka-user] Actor lifecycle with regard to unresponsive actors

2015-01-08 Thread Matan Safriel
Hi, I have read this other thread about the case of a remote being unavailable https://groups.google.com/forum/#!msg/akka-user/68TuTZLxqFI/3toNcO8yvMMJ. I assume it still applies to the most current version (?). My question is, how do both the supervision system (the part that's above user

[akka-user] support for akka persistent plugins

2015-01-08 Thread Tim Pigden
Which, if any, of the main target plugins (Cassandra, etc) are supported by Typesafe or commercially via other parties? -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search the archives:

[akka-user] is this a sensible problem for perdistence?

2015-01-08 Thread Tim Pigden
Hi I'm looking at modelling a large parcel delivery system with approximately 300k - 1m parcels per day depending on time of year. Each of those parcels has its own life cycle from assignment to a trip through eventual delivery. If parcels are on a route, then, for example, a delivery event at

[akka-user] akka-http respond with result of an actor call (java-api)

2015-01-08 Thread Peter
Hello, I'm playing arround with the Java-API of the new akka-http server and I would like to reply to a request with the result of an asynchronous actor (i.e. some kind of DB-query). I would have expected that I somehow can pass a Future to the context.complete or a Future entity. But this

[akka-user] Re: is this a sensible problem for persistence?

2015-01-08 Thread Tim Pigden
Hmm - on reading other threads and reflection I think I may have the wrong model here. The information about the ETA is possibly not something that should be persisted. It's not hard data. And perhaps my parcel should be split between a persisting actor (still need 1m of them) and some sort of

Re: [akka-user] Getting strange error 2.4-Snapshot with stream+http 1.0-M2

2015-01-08 Thread tigerfoot
Yessir. That was the issue. Rebuilt against 2.3.x and its stable. Thanks! On Wednesday, January 7, 2015 2:42:56 AM UTC-6, drewhk wrote: Hi, Streams is compiled against Akka 2.3.x which is not guaranteed to be binary compatible with 2.4. I expect that the above code to work with Akka

[akka-user] Re: Actor lifecycle with regard to unresponsive actors

2015-01-08 Thread bearrito
Your first step would probably be the documentation at : http://doc.akka.io/docs/akka/snapshot/scala/remoting.html In particular the sections - Lifecycle and Failure Recovery Model You could also have a look at http://doc.akka.io/docs/akka/snapshot/general/configuration.html and any of the

[akka-user] Re: Actor lifecycle with regard to unresponsive actors

2015-01-08 Thread Matan Safriel
Thanks for the reminder. The Phi Accrual Failure Detector is nice, although it is unfortunate that tuning the threshold is an art (see mention of EC2 in http://doc.akka.io/docs/akka/snapshot/scala/remoting.html