> On 08 Sep 2015, at 07:39, Richard Rodseth wrote:
>
> Thanks for the link to that sample.
> The other problem in doing per-request actors without ask pattern, as in the
> net-a-porter sample seems to be that Routes are no longer defined as
> RequestContext => Unit. Any thoughts on that? Are we
Thanks for the link to that sample.
The other problem in doing per-request actors without ask pattern, as in
the net-a-porter sample seems to be that Routes are no longer defined as
RequestContext => Unit. Any thoughts on that? Are we now required to use
Futures (or Flows?) to bridge routing with a
> On 07 Sep 2015, at 19:32, Richard Rodseth wrote:
>
> Maybe just move the bind call into my routing actor, in response to some sort
> of Start message ?
Yep.
Here’s a similar example:
https://github.com/hseeberger/reactive-flows/blob/master/src/main/scala/de/heikoseeberger/reactiveflows/Http
Maybe just move the bind call into my routing actor, in response to some
sort of Start message ?
On Mon, Sep 7, 2015 at 8:38 AM, Richard Rodseth wrote:
> I'm trying Akka Http for the first time, coming from Spray. In Spray I
> have a routing actor which extends HttpService and is passed to Http
I've run into the same problem. How to do per-request actors rather than
ask pattern with Akka Http, and I'm afraid I don't understand how
handlerFlow helps. I've started a separate thread, but if either of you can
elaborate that would be great. The Spray migration page is still marked
TODO.
Thank
I'm trying Akka Http for the first time, coming from Spray. In Spray I have
a routing actor which extends HttpService and is passed to HttpBind as
shown below. This way routes can create per-request actors as a child of
the routing actor.
What would be the equivalent in Akka Http?
I'm not so worr
Tal,
You decided to use a experimental features (Akka Persistence in 2.3), so the
issues you are facing now are no surprise.
Just my 5 cents
Heiko
> On 07 Sep 2015, at 16:06, Tal Pressman wrote:
>
> Hi,
>
> Akka 2.4 is coming, bringing with it Persistence Queries, which for the most
> part
Hi Tal,
Thanks for feedback. PersistentView will remain until Persistence Query and
Streams are non-experimental. It will exist for the full 2.4.x lifecycle.
We will not remove it without a replacement, i.e. if journal plugins don't
implement corresponding query we have failed and must revert the
Ok so you have the seq at that point still, yup then mapConcat(identity) is
your friend.
On Sep 7, 2015 3:39 PM, "Endre Varga" wrote:
> Isn't it mapConcat what you are looking for?
>
> -Endre
>
> On Mon, Sep 7, 2015 at 4:13 PM, Ivan Baisi wrote:
>
>> I'm doing something like that for now:
>>
>>
Isn't it mapConcat what you are looking for?
-Endre
On Mon, Sep 7, 2015 at 4:13 PM, Ivan Baisi wrote:
> I'm doing something like that for now:
>
> .map({ x => x.foldLeft("")((fStr, str) => fStr + str + "\r\n") })
>
> but this ends up in many json in one kafka message, and what I'd like to
> ach
I'm doing something like that for now:
.map({ x => x.foldLeft("")((fStr, str) => fStr + str + "\r\n") })
but this ends up in many json in one kafka message, and what I'd like to
achieve is having one json per message being pushed to kafka
On Monday, September 7, 2015 at 3:53:38 PM UTC+2, Konrad
Hi,
Akka 2.4 is coming, bringing with it Persistence Queries, which for the
most part look really great. However, there are some issues with it that I
find problematic.
The first regards dependencies - 2.4.0 deprecates PersistentView, but the
recommended classes are part of an entirely differe
Why not .map(json => makeTheString(json))?
On Sep 7, 2015 13:30, "Ivan Baisi" wrote:
> Hi all,
>
> So I have a problem I cannot find out how to solve.
>
> I have a flow that receives many elements, and as I have to access a db
> with that data, I have to group them so I query the db once instead
Hi all,
So I have a problem I cannot find out how to solve.
I have a flow that receives many elements, and as I have to access a db
with that data, I have to group them so I query the db once instead of 1000
times:
deleteActivityFlow.grouped(1000)
The problem is that after doing all the proce
I'm using AkkaSystem in a test.
system config has enabled remoting
akka {
actor {
creation-timeout = 5s
}
remote {
enabled-transports = ["akka.remote.netty.tcp"]
netty.tcp {
hostname = "localhost"
port = 7337
}
}
cluster {
auto-join = off
}
}
I try to
15 matches
Mail list logo
