[akka-user] DDD/CQRS - Modifying write model solely to support read model projection

I asked this over on the DDD/CQRS list, but didn't get a reply, so I thought I'd try here. Imagine a system to notify users about alarms. I'm using Akka Persistence which supports streaming projections from the event store to the read side. I'm considering three aggregates, (alarm)Definition, Sit

Re: [akka-user] Re: Akka Streams: Implementing handshake/authentication/etc

Thanks for the reply! I'm trying to learn Akka streams by green fielding this project (typically I like to learn new things by trying to make something useful). So I guess what I'm asking is whether or not there's an accepted pattern to establishing a steady state of a Stream. More generally, i

[akka-user] Re: How to configure cluster for two machines

It's working now. The problem was that access to port 2552 was being blocked by the firewall in hostA. Regards El miércoles, 21 de septiembre de 2016, 15:29:34 (UTC-3), Gerard W escribió: > > I'm using Akka 2.3.15 (java) and I'm trying to get a cluster with two > members in two different hosts.

[akka-user] Re: Cluster inconsistency when using AWS EC2 autoscale groups ('No route to host' not triggering unreachable state)

i also redefined values in failure detector > failure-detector { > threshold = 16 > acceptable-heartbeat-pause = 10s > heartbeat-interval = 3s > #expected-response-after = 20s #this means time for receiving first > gossip from anyone or node will be detected as broken

[akka-user] [akka-stream] How to implement Spark's cogroup/join operation

Hey, I'm reimplementing a few Spark batch jobs as akka streams. I got stuck at the last one that takes two PairRdd[Key,Value] and cogroups them by Key which returns an Rdd[Key,Seq[Value]] and then it processes Seq[Value] for each of the unique Keys that are present in both original PairRdds, w

[akka-user] Re: Cluster inconsistency when using AWS EC2 autoscale groups ('No route to host' not triggering unreachable state)

> > > com.typesafe.akka > akka-cluster_2.11 > 2.4.7 > > akka version -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> S

Re: [akka-user] Re: Akka Streams: Implementing handshake/authentication/etc

It is hard to give much input without knowing the state of the code you want to add this one time activity into. I'm inclined to think you could use a factory function that accepts the credentials and returns a stream. Have a special case message be processed at the start by prepending it, thus pro

[akka-user] Cluster inconsistency when using AWS EC2 autoscale groups ('No route to host' not triggering unreachable state)

I have some stateless actors that running at nodes in AWS EC2 autoscale group. That means that if load is rising - new node will be spawned, and the load subsides, those extra server will be closed(server termination). But closed not gracefully, just like switching power off. At this situation c

[akka-user] Re: Akka Streams: Implementing handshake/authentication/etc

I am an Akka Stream newbie and this kind of problems is the main reason why we are not using Akka Streams more widely. I also feel the lack of documentation in this kind of cases. A solution I can imagine is to have two sources, one of them used when the connection is not handshaked and the oth

[akka-user] Re: Memory Bounding Akka Streams

Akka Streams has several stages that backpreassures on different conditions, as you can see here . As far as I know, there is no built-in stage that backpreassure when a number of bytes are buffered. The buffer stage you are

[akka-user] missing type akka.stream.impl.VirtualProcessor$WrappedSubscription$$SubscriptionState

Hi all, starting an application I see the following log output: [AppClassLoader@1f17ae12] error can't determine implemented interfaces of missing type akka.stream.impl.VirtualProcessor$WrappedSubscription$$SubscriptionState when processing declare parents akka.stream.impl.VirtualProc