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
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
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
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
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
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:
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.
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
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
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:
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
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
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
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
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
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)