Re: [akka-user] SSL Support of akka-http(0.9)

2015-02-09 Thread tigerfoot
Any updates on SSL on the client? It wasn't clear to me from the tickets. I'm having the same issue. Thanks! Greg On Friday, November 7, 2014 at 9:56:16 AM UTC-6, Martynas Mickevičius wrote: Hello Zirou, I am afraid this is still not possible also with the just released 0.10. You can

[akka-user] Akka Streams + Persistence?

2015-02-09 Thread Steve Myers
Hi, is anyone else trying to use the new Akka Streams with Akka Persistence? Has anyone created any code examples yet showing how to use them together? Thanks! Steve -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html

[akka-user] [akka-http] Routing dsl and streams integration

2015-02-09 Thread Alexey Romanchuk
Hello! As I understand from docs akka-http seamless integrates with akka-stream by passing flow to handleWith method. Also we have well known routing dsl from spray with all these nested directives. But I can not figure out how to use them together. I want to have routing dsl together with

Re: [akka-user] akka-http long-lived connection backpressure problem

2015-02-09 Thread Jim Hazen
Thanks for creating the issue. Please note that there were actually two issues discovered. The client flow issue was logged, but the server request parsing issue wasn't. The rest of this post is really just going through my thought process, so that the group can benefit from an analysis of

Re: [akka-user] akka-http long-lived connection backpressure problem

2015-02-09 Thread Jim Hazen
Now that I think even more on the problem the more it seems that we're trying to solve too much within a single flow. There are concepts that ought to be independent that we're forcing to become dependent. I still like the independent streams model. I'd start with that, but with a

[akka-user] cluster sharding with at least once delivery

2015-02-09 Thread 최영규
hi. every body. i'm newbie akka. i'm sorry but i don't english very well. i'm using akka cluster sharding. it's very good and nice performance. but i've got some problems. when node was unreachable, it to be down(auto down). but coordinator send a message to unreachable node until it's going

Re: [akka-user] akka.io downloads - no java?

2015-02-09 Thread Roland Kuhn
8 feb 2015 kl. 22:59 skrev Viktor Klang viktor.kl...@gmail.com: Hi Jeffrey, Akka is built in Scala but offers Java APIs, so the Scala downloads should be just fine. Small emphasis correction: a JAR file is a JAR file (independent of programming language), and in the case of Akka each

Re: [akka-user] Multiple sharded actors for the same entry

2015-02-09 Thread Magnus H
Hi Patrik, The message extractor is quite simple, I've modified some class names but basically looks like this: public final static ShardRegion.MessageExtractor messageExtractor = new ShardRegion.MessageExtractor() { @Override public String entryId(Object msg) { return

Re: [akka-user] ANNOUNCE: Akka Streams HTTP 1.0-M3

2015-02-09 Thread Ivan Topolnjak
Hello there! It's really exciting to see where the Akka Streams HTTP projects are heading, congrats to the team and to all contributors for such a great gift to the community. Now, I know you get asked for WebSockets support a lot, but this announcement made me wonder: Is the first release of

Re: [akka-user] ActorSystem disappear [akka 2.3.8 , 2.3.9]

2015-02-09 Thread Wolfgang Friedl
Hi Roland! I was out on vacation, so sorry for may delayed response. Its exactly happed like I described. The JVM was still running but the actorsystem was gone of course with all its actors. Sometimes the problem occurred after a few minutes sometimes it happed after a few hours. Before the

Re: [akka-user] Which is the preferred way to get the current set of cluster nodes?

2015-02-09 Thread Patrik Nordwall
On Wed, Feb 4, 2015 at 10:22 PM, Steve Rehrauer steve.rehra...@gmail.com wrote: Our clustered app has a cluster singleton actor that constructs a Cluster instance, and also subscribes to cluster events. If you ask it, What are the current nodes? it uses cluster.state.members. I.e.,

Re: [akka-user] ActorSystem disappear [akka 2.3.8 , 2.3.9]

2015-02-09 Thread Wolfgang Friedl
Hi Patrik! Indeed it was very strange! Before we added the println to the shutdown-hook of the the Actorsystem the only thing we found in the log was some shutdown info of reactive mongo. 04:12:24.094 DEBUG Cluster Node [akka.tcp://ourprogr...@hostname.com:3552] - Heartbeat to

Re: [akka-user] Re: How to execute the defer-callback before processing the next command?

2015-02-09 Thread Patrik Nordwall
On Mon, Feb 9, 2015 at 1:30 PM, Anders Båtstrand ander...@gmail.com wrote: Done: https://github.com/akka/akka/issues/16797 The reason I am missing the defer that executes before the next message is processed, is because I am re-using the callbacks. Callbacks in Java are so verbose that I

Re: [akka-user] Re: How to execute the defer-callback before processing the next command?

2015-02-09 Thread Anders Båtstrand
If you add an inline implementation of the Procedure (without lambdas, I am stuck with Java 7), it gets verbose, after my taste... :-) Anders On 9 February 2015 at 14:41, Patrik Nordwall patrik.nordw...@gmail.com wrote: On Mon, Feb 9, 2015 at 1:30 PM, Anders Båtstrand ander...@gmail.com

Re: [akka-user] Multiple sharded actors for the same entry

2015-02-09 Thread Patrik Nordwall
On Mon, Feb 9, 2015 at 6:15 PM, Magnus H magnus.holtl...@gmail.com wrote: Hi Patrik, The message extractor is quite simple, I've modified some class names but basically looks like this: public final static ShardRegion.MessageExtractor messageExtractor = new ShardRegion.MessageExtractor() {

[akka-user] using Future with akka actor

2015-02-09 Thread Krishna Kadam
Hi all, I am trying to use Akka Actors as alternative to sticky threads which are callable threads and Future is used to to return Transaction information from those callable threads, Can I use Future or return such information to monitor the status? Thanks and regards -- Read the