[akka-user] Akka stream compression / decompression

Hello, I’m currently using akka stream to stream some big files and it works quit well :) But in the FlowGraph stream I want to add some compression and decompression steps. Compression seems working correctly, but I’ve got some offset errors when the decompression is executed.

[akka-user] Multiple Akka Cluster with distributed journal

Hi, We have two Akka Clusters(using sharding extension as well) each of two nodes in two data centers which takes distinct traffic, Data Center 1 had Akka cluster 1 of two nodes and Data Center 2 has Akka cluster 2 with two nodes again. We have distributed journal ( Cassandra ) configured for b

[akka-user] When is a persistent view done recovering

Hello all, In akka 2.3.6 persistence the docs seem to suggest that a persistent view has these methods: 1. def recoveryRunning: Boolean 2. def recoveryFinished: Boolean But these methods are on a PersistentActor, not a PersistentView. How does a view check to see if the messages it's

Re: [akka-user] Akka Future Java chaining a series of futures together?

Can i suggest an alternative? Why not use actors to model this computation? For example, you could have a class ProcessAssetsActor. The class has a Map called assetFutures, and a List called assets containing the received assets. In the preStart() method, you create a future to get the asset

[akka-user] Akka Future Java chaining a series of futures together?

Hi, I have the following events that I'm trying to put into a non blocking way. The events are as follows 1. database call to get list of asset ids. 2. create a list of futures to get assets (getting assets can take a while and are independent of one another) 3. process all the assets and retur

[akka-user] equivalent of scalaz-stream nondeterminism.njoin

Hi all, I've asked this question in various forms over the years, and I'm pleased to find out that scalaz-stream actually answers it: https://github.com/fommil/rx-playground/blob/master/src/main/scala/com/github/fommil/rx/scratch.scala#L202 Does akka-stream have an equivalent to the nondetermin

[akka-user] Actor scheduling or messaging problem or a problem i can't address

I have a strange problem using Akka actors. The scenario is like this; Actor A creates Actor B1 and Actor B1 creates "n" actors which are responsible for execiting tasks. So A is parent of B1 and B1 is parent of lets say b1, b2, b3, In A i have scheduled a ticker so that A checks every 10se

Re: [akka-user] Akka REST

There are a couple of Activator templates. It's common to use Spray, which is in the process of becoming Akka HTTP. https://typesafe.com/activator/template/activator-akka-spray On Tue, Oct 7, 2014 at 4:52 AM, naveen gayar wrote: > Hi > > > Any example of Akka as a RESTful service? > > Thanks >

[akka-user] Re: Akka REST

Spray examples On Tuesday, 7 October 2014 18:52:22 UTC+7, naveen gayar wrote: > > Hi > > > Any example of Akka as a RESTful service? > > Thanks > navajyothi > -- >> Read the docs: http://akka.io/docs/

[akka-user] Akka REST

Hi Any example of Akka as a RESTful service? Thanks navajyothi -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-us

Re: [akka-user] Re: Akka Multi Node Testing

Thank you! Jen 2014-10-07 10:27 GMT+02:00 Martynas Mickevičius < martynas.mickevic...@typesafe.com>: > Hi Jen, > > when this bug is closed it will have a milestone corresponding to the Akka > version it has been fixed. > > On Sun, Oct 5, 2014 at 9:41 AM, jen wrote: > >> Many thanks for the usef

Re: [akka-user] Critical:Multiple Views For One PersistentActor

Hi Martynas, Thanks. Still I have open questions. We are working on POC using akka persistence. Want to use views, but looking clarity on below, Are there any drawbacks of multiple views for one persistent actor? I have updated myself from this thread

[akka-user] Re: Akka Persistence on the Query Side: The Conclusion

Will updated read side include ability to replay views from multiple streams? It's common scenario when view may need to handle events of some types from multiple different event sources. I think main problem here is causal ordering of events across multiple streams. And as I understand such "e

Re: [akka-user] Akka starting one thread per actor

When you use Await (and scala.concurrent.blocking) you are going to use managed blocking, which in this case, for the ForkJoinPool, means spawning new threads to avoid ending up in a stall. Avoid blocking, is the general rule here. :) On Tue, Oct 7, 2014 at 11:46 AM, wrote: > Ya I was blocking u

Re: [akka-user] Akka starting one thread per actor

Ya I was blocking using Await.result. Chris On Tuesday, October 7, 2014 2:31:49 AM UTC-7, √ wrote: > > Wdym "catch the TimeoutException"? You were blocking on the future? > > On Tue, Oct 7, 2014 at 11:28 AM, > wrote: > >> Really strange bug. So I had an ask when it should have been tell, but

Re: [akka-user] Akka starting one thread per actor

Wdym "catch the TimeoutException"? You were blocking on the future? On Tue, Oct 7, 2014 at 11:28 AM, wrote: > Really strange bug. So I had an ask when it should have been tell, but it > was timing out correctly after a couple seconds. The thing is that the ask > I was using was written in jrub

Re: [akka-user] Akka starting one thread per actor

Really strange bug. So I had an ask when it should have been tell, but it was timing out correctly after a couple seconds. The thing is that the ask I was using was written in jruby, just a thin wrapper. After catching the TimeoutException the code moves on, nothing is blocking, but the threa

Re: [akka-user] Critical:Multiple Views For One PersistentActor

Hello Prakhyat, yes, you can have multiple PersistentViews for one persistenceId. PersistentViews will have a bit of a rethink in the near future as noted in this thread . On Mon, Oct 6, 2014 at 9:40 AM, Prakhyat Mallikarjun wrote:

Re: [akka-user] Bind exception with multiple Akka cluster nodes on same machine

Thanks for the reply Martynas. You were spot-on !!! I was actually starting actorsystems with overlapping ports - my bad ! Thanks Muthu On Tuesday, 7 October 2014 13:42:18 UTC+5:30, Martynas Mickevičius wrote: > > Hi Muthu, > > since cluster starts and is working it seems that you start mul

Re: [akka-user] Akka scheduleOnce question for sending emails - beginner

Hello Jay, have you tried adding a debug statement in the sendMail method, to see if it is not called repeatedly? If you see it being called more than needed print out stack trace and see from where it is initiated. I would presume that MailJob class extends Runnable, right? Check if you are not

Re: [akka-user] Re: Akka Multi Node Testing

Hi Jen, when this bug is closed it will have a milestone corresponding to the Akka version it has been fixed. On Sun, Oct 5, 2014 at 9:41 AM, jen wrote: > Many thanks for the useful comments! Definitely I will learn Scala :) > Could you tell me what is the expected due date of the 2.3.x milesto

Re: [akka-user] Akka design patterns for high read/write environments (multiplayer games)

Hi Chris, On Sun, Oct 5, 2014 at 1:52 AM, wrote: > I have a multiplayer game framework that is written on top of akka, and > there is a recurring problem that to this day I haven't really found a > 'best' solution for. > > I'm going to keep this simple and leave out a lot of the details for now.

Re: [akka-user] Akka starting one thread per actor

My bet: You're doing blocking (either Await or scala.concurrent.blocking {}) On Tue, Oct 7, 2014 at 10:09 AM, wrote: > Never seen this before and curious what I'm doing to trigger it. > > I'm seeing akka start up one dispatcher thread for each of a specific > actor I am using. 500 actors 500 th

Re: [akka-user] Bind exception with multiple Akka cluster nodes on same machine

Hi Muthu, since cluster starts and is working it seems that you start multiple nodes on port 1551 next to the nodes with changed port. Do you change remote.netty.tcp.port in code? Check if you do not start ActorSystem before the change. On Sat, Oct 4, 2014 at 10:53 PM, Muthukumaran Kothandaraman

[akka-user] Akka starting one thread per actor

Never seen this before and curious what I'm doing to trigger it. I'm seeing akka start up one dispatcher thread for each of a specific actor I am using. 500 actors 500 threads. Then over a couple of minutes they all go away, down to what it normally is, just a small pool of 10 or so. This is

Re: [akka-user] From an Akka newbie: a design challenge

Hi Khoa, it is great that you find Akka exciting. Let me help you with your questions. On Fri, Oct 3, 2014 at 10:07 PM, Khoa Nguyen wrote: > I am supposed to design and implement a distributed solution for a client. > I look at Akka and the Actor's model and immediately fall in love :-) But > c

[akka-user] Problem with Akka-streams and IllegalStateExceptions

The following code fails to run with the exception *java.lang.IllegalStateException: FanoutOutputs only supports one subscriber (which is allowed, see reactive-streams specification, rule 1.12)*: val bcast = Broadcast[String] val merge = Merge[String] val in1 = IterableSource(List("a"))

Re: [akka-user] [akka-stream] Some problems with ThunkSource

Thanks! понедельник, 6 октября 2014 г., 20:02:27 UTC+4 пользователь Patrik Nordwall написал: > > That is a know issue in > scaladsl2 in version 0.7 and 0.8. It is fixed in upcoming 0.9. > > You can probably work around it by using an Iterator instead.

Re: [akka-user] Best book(s) on "distributed system" ?

A Distributed Systems Reading List - http://dancres.github.io/Pages/ On Tue, Sep 30, 2014 at 3:17 PM, Joseph Pachod wrote: > Hello > > Our small software shop has recently been bought and now we face the issue > of building a distributed system, meaning by that moving from monolithic > web bas

Re: [akka-user] DequeBasedMailbox required in UntypedPersistentActor

On Tue, Oct 7, 2014 at 9:07 AM, Michael Pisula < michael.pis...@googlemail.com> wrote: > Hey Patrik, > > Thanks a lot, that did the trick. > Using 'Props.create( actorClass, creator )' was the way to go. However, we > do not use Java 8 Lambdas nor anonymous mixin composition. In fact, as we > use

Re: [akka-user] DequeBasedMailbox required in UntypedPersistentActor

Hey Patrik, Thanks a lot, that did the trick. Using 'Props.create( actorClass, creator )' was the way to go. However, we do not use Java 8 Lambdas nor anonymous mixin composition. In fact, as we use Java, our Actor were UntypedPersistentActorsWithAtLeastOnceDelivery. I will try and see if I can