[akka-user] Persistent actor partitioning question

2015-08-12 Thread Dan Di Spaltro
So imagine I am building a session tracking system. Where I am feeding the session header, events, and other things about the session and maintaining its state in a single actor. Now I am looking to add fault tolerance to that actor for when I need to either rebuild my Index for slicing and

Re: [akka-user] Re: akka-http 1.0 RC and SSL and Java

2015-08-12 Thread Will Sargent
The SSLContext is responsible for handling the trust store -- you set it up and pass that into akka-http using HttpsContext.create(sslContext,...). How to set up the SSLContext is a bit confusing. There are examples in the guides for Android:

Re: [akka-user] Re: Akka Streams and OAuth 2.0

2015-08-12 Thread David Pinn
I'm confortable with Scala, but for reasons outside my control, Java was mandated for this project. We're using streams for another part of the application, in a somewhat simpler scenario. This conversation has been very helpful. The gems are these, I think: a) Treat the refresh flow as normal

[akka-user] Transforming elements of a stream more than ones inside a flow

2015-08-12 Thread wwagner4
I cannot find a solution for accessing the elements of a stream more than ones inside a flow without buffering the complete stream. To illustrate the problem I created the following example: def randomIntegersSource(size: Int): Source[Int, _] = { val iter =

[akka-user] akka-streams example for accessing a database or similar?

2015-08-12 Thread algermissen1971
Hi all, I am looking for an akka-streams example that shows how one would approach talking to databases (or an FTP server in my case). Besides the basic question of how to create a Source or Sink on top of a database driver (or SFTP connection for that matter) I am looking for best practices

Re: [akka-user] Best practice for communicating with a cluster: client vs direct membership

2015-08-12 Thread Carsten Saathoff
Hi, I agree that it strongly depends on your application. But it is an aspect that one should consider when planning the architecture, that's why I mentioned it. best Carsten Am Mittwoch, 12. August 2015 10:40:20 UTC+2 schrieb Heiko Seeberger: Carsten, I don’t think your argument is

Re: [akka-user] Re: Akka Streams and OAuth 2.0

2015-08-12 Thread Lance Arlaus
Oh, jeez. Yeah, that's entirely hideous. You know there's a cure for this disease. It's called Scala. However, side effects may include crawling compiles, awkward builds, and speaking optionally in futures :-) Seriously, if I'd known you were approaching this from Java, I'd advised against

Re: [akka-user] Re: Coordinator in cluster sharding: No oldest node

2015-08-12 Thread Patrik Nordwall
We have improved the way roles and proxies work significantly in 2.4-M2: http://doc.akka.io/docs/akka/2.4-M2/scala/cluster-sharding.html On Mon, Aug 10, 2015 at 9:41 PM, Yifei sunyifei1...@gmail.com wrote: Thanks Patrik, I have the scenario shown below: There are 3 shard regions, A, B and

Re: [akka-user] Using cluster aware pool routers with remote deployment

2015-08-12 Thread Konrad Malawski
Uff, indeed :-) Gotta watch out and only keep as many ActorSystems as you really intent to have. Glad you found the solution, happy hakking! --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 10 August 2015 at 10:31:31, n...@rubell.com (n...@rubell.com) wrote: Hi, I am trying to use

[akka-user] Re: Using cluster aware pool routers with remote deployment

2015-08-12 Thread nick
After looking into the details of the problem closer, I found the problem is not in the configuration but rather in the code itself. I've made a typo and had: def system = ActorSystem(mySystem) instead of val system = As a result the actor system was instancitated each time system was

[akka-user] Application fails silently at http request, what could be wrong?

2015-08-12 Thread Nicolau Werneck
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