Re: [akka-user] Akka Persistence - Views with multiple processors

2014-04-21 Thread Patrik Nordwall
On Sun, Apr 20, 2014 at 6:05 PM, Olger Warnier ol...@spectare.nl wrote: On Sunday, April 20, 2014 4:59:22 PM UTC+2, Patrik Nordwall wrote: On Sun, Apr 20, 2014 at 2:47 PM, Olger Warnier ol...@spectare.nl wrote: Hi Patrick, Sounds like an interesting approach, storing some meta-data at

Re: [akka-user] Re: [persistence] in memory journal for testing

2014-04-21 Thread Patrik Nordwall
Hi Tim, As Todd mentioned there is a community maintained in-memory journal, but that is not the same as the one you found in the akka sources. We have not promoted (documented) the akka in-memory journal because we are not sure that it is ready for general consumption and the maintenance

[akka-user] can't get community in-memory-journal to work

2014-04-21 Thread Tim Pigden
Hi I can't get the in-memory-journal to configure. The documentation says simply use: akka.persistence.journal.plugin = in-memory-journal but this gives me an error: default-akka.actor.default-dispatcher-4 No configuration setting found for key 'in-memory-journal'

Re: [akka-user] 'Scatter-GatherAllDone' pattern questions

2014-04-21 Thread Patrik Nordwall
Hi, On Fri, Apr 18, 2014 at 10:55 AM, Alexey Shuksto seig...@gmail.com wrote: Hello fellow hAkkers, In our project we use same business logic several times: 1. Manager actor `M` receives work order `WorkOrder(n, time)`; 2. `M` distributes work over `n` worker actors `W` (`n` differs

Re: [akka-user] can't get community in-memory-journal to work

2014-04-21 Thread Tim Pigden
doh! RTFM didn't read the bit about publishLocal and assumed intellij had gone and got it from a repo Thanks On 21 April 2014 09:16, Patrik Nordwall patrik.nordw...@gmail.com wrote: Have you added the dependency (jar in classpath)? Otherwise, raise an issue in the github repo of the external

Re: [akka-user] SingleConsumerOnlyUnboundedMailbox

2014-04-21 Thread Patrik Nordwall
Hi Aaron, withMailbox refers to a configuration section of the mailbox type, i.e. use this instead withMailbox(single-consumer-mailbox) and in your application.conf: single-consumer-mailbox { mailbox-type = akka.dispatch.SingleConsumerOnlyUnboundedMailbox } Cheers, Patrik On Fri, Apr 18,

[akka-user] akka streams infinite data source example

2014-04-21 Thread Sam Halliday
Hi all, I am very excited by akka streams -- it aims to solve a problem that I see time and time again. Every time I post to this list it feels like the solution is always wait until Akka Streams is released Finally, it is here! I intend to read the documentation fully, but I was a little

Re: [akka-user] akka streams infinite data source example

2014-04-21 Thread Patrik Nordwall
Hi Sam, 21 apr 2014 kl. 12:28 skrev Sam Halliday sam.halli...@gmail.com: Hi all, I am very excited by akka streams -- it aims to solve a problem that I see time and time again. Every time I post to this list it feels like the solution is always wait until Akka Streams is released

Re: [akka-user] Reactive / Akka streams of ByteStrings

2014-04-21 Thread Patrik Nordwall
20 apr 2014 kl. 00:32 skrev Daniel Armak danar...@gmail.com: Hi, How would I use reactive streams in general, and/or akka streams in particular, to represent a stream of binary data? I'm thinking of all binary streams that don't have a natural division into chunks of a fixed (small)

Re: [akka-user] akka streams infinite data source example

2014-04-21 Thread Sam Halliday
On Monday, 21 April 2014 12:32:57 UTC+1, Patrik Nordwall wrote: I intend to read the documentation fully, but I was a little disappointed that the activator examples did not have a simple example with an (effectively) infinite data source that can only be polled in serial, with parallel

Re: [akka-user] akka streams infinite data source example

2014-04-21 Thread Patrik Nordwall
21 apr 2014 kl. 13:55 skrev Sam Halliday sam.halli...@gmail.com: On Monday, 21 April 2014 12:32:57 UTC+1, Patrik Nordwall wrote: I intend to read the documentation fully, but I was a little disappointed that the activator examples did not have a simple example with an (effectively)

Re: [akka-user] Reactive / Akka streams of ByteStrings

2014-04-21 Thread Daniel Armak
Hi Patrik, That can be done, but what bothers me is the potential lack of standardization. Every programmer will solve this problem all over again for each stream they build. Even if particular Reactive Streams implementations offer generic tools, they won't be compatible across implementations

Re: [akka-user] Best way to communicate with an Actor?

2014-04-21 Thread Chanan Braunstein
If you start with the assumption that you have the ActorRefs for the X,Y,Z in someactor, I don't think you have a problem. Just tell the 3 actors directly. -- Read the docs: http://akka.io/docs/ Check the FAQ: http://doc.akka.io/docs/akka/current/additional/faq.html Search

[akka-user] remote class loading

2014-04-21 Thread Anders Bech Mellson
I am very new to Akka and still just playing around with it. I wonder if it is possible to use Akka to do dynamic class loading. The scenario is a server / client setup where the server is never rebooted. At compile time the server knows about a trait which I can pattern match against. This

[akka-user] akka-kafka consumer

2014-04-21 Thread Scott Clasen
Since there were a few kafka related questions here lately, figured I would factor this code out of some stuff I'm doing in case it's of use to others. https://github.com/sclasen/akka-kafka The consumer does explicit management of committing offsets, and allows actor based async processing of

Re: [akka-user] Akka 2.3.2 Released

2014-04-21 Thread Erik van Oosten
Hello, Thanks for the new release. I am missing akka-testkit 2.3.2 for Scala 2.11 from maven central. Is this still forthcoming, or is akka-testkit replaced by some other module? Kind regards, Erik. Patrik Nordwall schreef op 09-04-14 15:16: /Dear hAkkers,/ We—the Akka committers—are