If I've got a persistence store using one particular persistence plugin and
I want to change to another, what would I have to do?
I can see I could run a utility program that opened the old store and sent
the messages to another processor to persist them, but can I run with 2
different plugins
Hi Eduardo,
Just to add more information, since the persistence support for sharding
allows persisted entries to be passivated (the actor is stopped to save
memory, but is restored from disk when needed) in which case the
ShardRegion - shardId association still needs to be maintained although no
Hi John,
My question is this.
- In a front end actor is the sending of a message as simple as attaining
a reference (in frontend actor onreceive) to the backend actor via an
ActorRef and then sending a message to the backend actor?
Yes, once you have the ActorRef of an actor you can send
Alternatively, if what you want is really to produce the input elements
(returning a Flow[T]) and only add a side-effecting operation, you can
implement it using `map`.
Daniel Armak
On Thu, Jul 24, 2014 at 11:35 AM, Akka Team akka.offic...@gmail.com wrote:
Hi Eric,
There is a foreach
Hi,
I am new to java akka model. For your information, i have a java akka
program running in eclipse. Unfortunately, i cannot run the sample program.
They is not error message but what i receive is you need to provide
exactly one argument: the class of the application supervisor actor. Can
WARNING: Not compiled
implicit final class DoToEach[T](flow: Flow[T]) extends AnyVal {
def doOnEach(f: T = Unit): Flow[T] = flow.map(t = { f(t); t })
}
flow.map(...).doOnEach(println).filter(...)
On Thu, Jul 24, 2014 at 10:59 AM, Daniel Armak danar...@gmail.com wrote:
Alternatively, if what
If I've got a persistence store using one particular persistence plugin and I
want to change to another, what would I have to do?
I can see I could run a utility program that opened the old store and sent the
messages to another processor to persist them, but can I run with 2 different
plugins
Yes, we are using passivation. Tx.
There is a way of retrieve the entries id's from the shardings?
There is a member called entries in the sharding region class but I don't know
if I have access to it.
Tx again.
El 24/07/2014, a las 10:19, Akka Team akka.offic...@gmail.com escribió:
I had a reply prepped yesterday but lost the draft (argh offline editing!).
Back to the topic though:
First of all, thank you very much for the elaborate reply. I guess I'll
get hacking away at some prototypes soon and so some performance testing close
to our use-case. Looking forward
Quite clear Endre, as always.
Many thanks again for your time!
Best regards from Spain.
On Thu, Jul 24, 2014 at 12:59 PM, Akka Team akka.offic...@gmail.com wrote:
Hi Eduardo,
There is no explicit table maintained for individual entries. Sharding
maintains the table what ShardRegions are
Ah yes - pimp my flow! And map works fine, definitely better than
Transformer.
Thanks guys!
-- Eric
On Thu, Jul 24, 2014 at 5:07 AM, √iktor Ҡlang viktor.kl...@gmail.com
wrote:
WARNING: Not compiled
implicit final class DoToEach[T](flow: Flow[T]) extends AnyVal {
def doOnEach(f: T =
Hello
Inspired by the
presentation http://www.slideshare.net/EvanChan2/akka-inproductionpnw-scala2013
I wanted to introduce stackable traits pattern to my Akka application. For
now I wanted to add logging of messages using LoggingReceive and basic
tracing with akka-tracing.
Following the
Hello Rich,
it is currently not possible to use FSM with PersistentActor.
We would like to provide this at some point (FSMs are certainly pretty and
useful), here’s the issue tracking this feature:
https://github.com/akka/akka/issues/15279
You’re welcome to either help us out in this one or just
HI Endre,
Thanks again for the info.
Just to confirm this sample on akka activator appears to be a
frontend/backend sample that I have been looking for:
akka-sample-cluster-java
I have some feedback below.
//#frontend
public class FactorialFrontend extends UntypedActor {
final int
14 matches
Mail list logo
