Now that nested persist works, is it still strongly suggested not to nest
persists? The way I see it, there are a few approaches:
1. Nested persists. In this model, my handler does (a) applyEvent (state
change) and (b) postApply (take action, including more persisting). This
allows me
A few 100 microseconds is a reasonable expectation for delivery of a a
message to a remote actor.
/Patrik
fre 2 dec. 2016 kl. 21:22 skrev 'Konstantinos Kougios' via Akka User List <
akka-user@googlegroups.com>:
> Hi Konrad,
>
> Thanks for the reply, thats good enough volume of messages :)
>
> Wha
Yup, and you don't need the null check, it will retry for any exception,
which here will be thrown by actorOf
fre 2 dec. 2016 kl. 21:17 skrev Richard Rodseth :
> Thank you! I was not aware of awaitAssert. I think the following should do
> the trick.
>
> watch(definitionReader)
>
> system.stop(def
Hi Konrad,
Thanks for the reply, thats good enough volume of messages :)
What if, say per 1 operation of mine, I will need say 30 messages to
complete it? But messages will be sequential, that is they won't be
fired in 1 go but the 1st msg will be send to the 1st actor who in turn
will send t
Thank you! I was not aware of awaitAssert. I think the following should do
the trick.
watch(definitionReader)
system.stop(definitionReader)
expectTerminated(definitionReader)
var definitionReader2: ActorRef = null
awaitAssert {
definitionReader2 = system.actorOf(actorProps, actorName)
de
*for Scala
--
>> 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-user
---
You received this message because you are subsc
Hello,
I do have big troubles installing akka in Textmate 2 on my macOS Sierra
MacBook.
Can someone help me out and give me a step by step instruction?
How am I doing this? :/
Thanks in advance!
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>>
For testing purposes you might need to optionally override that way of
defining the persistenceId by passing it in as constructor parameter.
Another way is to retry the actorOf in the test until it is successful.
awaitAssert in testkit can be useful for that.
fre 2 dec. 2016 kl. 20:16 skrev Richa
I see now that
https://github.com/akka/akka/blob/release-2.4/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala
works by generating a unique id in beforeEach().
But I wonder how all your customers test recovery of their persistent
sharded entities when they follow your ex
I wondered about that, but the persistence id is derived from the name
(it's an aggregate root)
override val persistenceId: String = "XYZ-" + self.path.name
On Fri, Dec 2, 2016 at 10:53 AM, Patrik Nordwall
wrote:
> You can start the second actor with a different actor name but with the
> same
You can start the second actor with a different actor name but with the
same persistenceId.
If you don't specify the actor name a unique name will be used.
/Patrik
fre 2 dec. 2016 kl. 19:43 skrev Richard Rodseth :
> I'm also looking here:
>
> https://github.com/akka/akka/blob/release-2.4/akka-pe
I'm also looking here:
https://github.com/akka/akka/blob/release-2.4/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala
There's a lot of inherited code in these tests, and it's unclear to me how
the issue is avoided here:
abstract class PersistentActorSpec(config: Config)
Hi, anyone knows if say I got 2 actors which send very quickly thousands of
small messages between them.
Millions of small messages is the happy case for Akka - this is exactly
what Actors love :-)
We've reached 700k+ 100byte sized messages per second on the new remoting
recently, and aim to stil
I see that TestActorRef is not an option with PersistentActor
http://doc.akka.io/docs/akka/2.4.1/scala/testing.html#Synchronous_Unit_Testing_with_TestActorRef
This is not the clearest paragraph, but perhaps provides an option:
"It may also be required during testing, when the test subject depend
Hi, anyone knows if say I got 2 actors which send very quickly thousands of
small messages between them. Will akka do any groupping of the messages and
send them in batches in order to reduce network traffic?
Thanks
--
>> Read the docs: http://akka.io/docs/
>> Check t
Martynas,
Thank you for the pointer. There is a lot of good example code to digest
there, if not just for understanding how people think in the context of
marshallers. I was about to resort to creating my own entity to ByteString
flows, but hopefully i can figure out a reasonable solution based on
James, have you seen this ticket:
https://github.com/akka/akka-http/issues/424
There is an example there, which might help you.
On Tue, Nov 29, 2016 at 1:43 PM, James Matlik
wrote:
> Would any one have suggestions on how to support content negotiation with
> a steaming Akka-HTTP response? I kno
Hi
How can I create a balancing pool with bounded mailbox?
I tried doing as below, but seems like it ignores the value and uses its
default unbounded mailbox
actorSystem.actorOf(BalancingPool(2
).props(Props(classOf[Test1])).withMailbox("custom-bounded-mailbox"),
"Actor1")
custom-bounded-mai
18 matches
Mail list logo
