[akka-user] Akka sharding security - is shardRegion custom behavior possible to implement this?

Hi all, I'm currently implementing an Akka Sharding based infrastructure and found a limitation with the solution that potentially becomes a security problem. There is the web layer (Play) and the data access layer of the akka cluster. The web layer communicates through Akka Sharding proxy

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

OK, I have now narrowed it down a bit more. I removed everything in any way related to akka-http, and then added back things until it breaks. It seems that the problem only happens when I use MediaTypes.`application/json` in a certain way. Now I am even more confused than before. Here is a

Re: [akka-user] future usage within an actor

Hi Ash, http://doc.akka.io/docs/akka/2.4.1/additional/faq.html#sender___getSender___disappears_when_I_use_Future_in_my_Actor__why_ On Tue, Jan 12, 2016 at 7:10 PM, ash.ta wrote: > hi hakkers, > > i have two actors: the first one patterns.ask() a message to the second > one

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

Just tried this from home. Also does not work. This is really weird. $ git clone https://github.com/rklaehn/invaliddependency $ cd invaliddependency $ sbt clean compile [info] Loading project definition from /Users/rklaehn/projects_git/rklaehn/invaliddependency/project [info] Set current

[akka-user] Asking a node to leave using akka-cluster command-line tool.

Hi, I have a 2-node akka cluster. When deploying updated code, the nodes are restarted one after the other with some time gap in between. This seems to be causing Unreachable/Quarantine issues. So, I want to ask each node to LEAVE the cluster before it is restarted. I am using the akka-cluster

Re: [akka-user] future usage within an actor

hi again, thanks for your prompt response. in such case, what in your opinion is the right way to implement something like async calls to db? to use the async driver from an actor with a dedicated separate dispatcher and block the async call itself? cheers -- >> Read the docs:

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

For reference, this is now tracked at: https://github.com/akka/akka/issues/19418 and https://issues.scala-lang.org/browse/SI-9621 --  Cheers, Konrad 'ktoso’ Malawski Akka @ Typesafe On 12 January 2016 at 20:19:56, rklaehn (rkla...@gmail.com) wrote: Just tried this from home. Also does not work.

[akka-user] Dependency problem when updating to akka-http 2.0.1

Hi all, we are trying out akka-http 2.0.1 with a pretty large code base. After fixing all compile errors, we get the following dependency error: [error] missing or invalid dependency detected while loading class file 'MediaType.class'. [error] Could not access type WithFixedCharset in trait

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

Hi Rüdiger, there were some changes in that area, it might help if you show the offending code. It also looks like you didn’t do a full clean before the build. Have you checked the migration guide? If we missed this point, please raise an issue. Regards, Roland > 12 jan 2016 kl. 16:00 skrev

[akka-user] Service discovery?

Hi, We are going to use Akka-HTTP as IPC in our new distributed system that is based on microservice architecture. How to perform Service discovery for akka-stream/akka-http in distributed system? What is the best way to implement this? Thanks, Igor -- >> Read the docs:

[akka-user] Re: Accessing materializer within a GraphStage

Hi Francesco, In general the GraphStage is meant to encapsulate smaller graph transformations than sub-graphs and the flow API and GraphDSL is the way to go combine graphs. So, one thing might be to reconsider if perhaps your GraphStage is doing too many things at one time and you could

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

Hi Roland, I did a sbt clean, and my colleague even deleted the ivy cache. We also don't know the offending code, since we do not intentionally use anything out of javadsl, such as akka.http.javadsl.model.MediaType. So I am a bit confused. The migration guide does not say anything about

Re: [akka-user] Dependency problem when updating to akka-http 2.0.1

It should work properly. There was a PR refactoring that area, indeed:  https://github.com/akka/akka/pull/19066/files Are you sure you don't have mixed up akka http dependencies or something like that via messy dependencies? You mention you looked at dependencyTree so that would show up there

[akka-user] future usage within an actor

hi hakkers, i have two actors: the first one patterns.ask() a message to the second one which returns a response: a snippet osender: ... public PartialFunction receive() { return ReceiveBuilder .match( Boolean.class, msg -> {

Re: [akka-user] Service discovery?

On 01/12/16 07:28, Igor Katz wrote: Hi, We are going to use Akka-HTTP as IPC in our new distributed system that is based on microservice architecture. How to perform Service discovery for akka-stream/akka-http in distributed system? What is the best way to implement this? what are your

[akka-user] Does akka streams support a getDataBytes() with context flow?

Isn't the following case typical for dealing with Http().superPool(...) flows? The superPool flow lets me nicely attach context to the HttResponse. Now I do not want to materialize the getDataBytes Source right away but pass it to flatMapConcat. Like in the following pseudo java code: 1)