How does the abstract persistent actor recover messages? Does it recover
all messages or only that were not delivered? Since we dont have confirm
messages how will it work?
We tried using AtleastOnce delivery but that did not help either. It was
recovering all messages from the cassandra on
To configure cassandra for akka in java using environment variables I am
writing the following code which is throwing the error
String contactPoints = "cassandra-journal.contact-points=" + envHelper
.getContactPoints();
contactPoints = contactPoints
this exception.
On Wednesday, 11 May 2016 08:56:46 UTC-5, Amruta wrote:
>
> Do I need to refresh/reload the actorSystem in some way?
>
> On Tuesday, 10 May 2016 09:29:07 UTC-5, Amruta wrote:
>>
>> I have scheduled a task that the actors carry out at a scheduled
>> time(every 5
Is it ok to use Mockito for mocking?
On Wednesday, 11 May 2016 08:44:30 UTC-5, Amruta wrote:
>
> We are using Akka concept for batch processing. The actors talk to
> different database and process large amount of data. Is there a way to test
> this system, without connecting
Do I need to refresh/reload the actorSystem in some way?
On Tuesday, 10 May 2016 09:29:07 UTC-5, Amruta wrote:
>
> I have scheduled a task that the actors carry out at a scheduled
> time(every 5 minutes). When I deploy my app the first time it runs fine but
> on the second and con
but before doing
that wanted to know if akka-test kit provides anything similar to that.
Thanks,
Amruta
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://do
I have scheduled a task that the actors carry out at a scheduled time(every
5 minutes). When I deploy my app the first time it runs fine but on the
second and consequent runs it gives the folllowing error
09:22:00.006 [schedulerFactoryBean_Worker-2] ERROR (:) - Job
reates children and supervises them as it needs to.
>
> --
> Konrad `ktoso` Malawski
> Akka <http://akka.io> @ Lightbend <http://lightbend.com>
>
> On 3 May 2016 at 00:54:28, Amruta (parul...@gmail.com )
> wrote:
>
> The persistent actor is called from a service
; the parent.
>
> --
> Konrad `ktoso` Malawski
> Akka <http://akka.io> @ Lightbend <http://lightbend.com>
>
> On 3 May 2016 at 00:38:38, Amruta (parul...@gmail.com )
> wrote:
>
> I have defined supervision strategy in my persistent actor(Java). This
> pe
I have defined supervision strategy in my persistent actor(Java). This
persistent actor has children actors and the supervision strategy applies
correctly. But how will the supervision work if the exception is thrown in
the Persistent actor itself? Is there a global way to define supervisor
Thank you Patrik.
On Friday, 8 April 2016 11:24:09 UTC-5, Amruta wrote:
>
> In Akka we are using cassandra to persist data. Does Akka automatically
> cleanup cassandra based on timestamp of messages or do we need to manually
> (in code) do it? If so any pointers woul
Hi,
I am using cassandra for journaling and storing snapshot in Akka(Java). I
take a snapshot after sending few(1-5) messages and then send next set of
messages(6-10). This takes a correct snapshot and I see sequence number 5
for my snapshot which looks right.
If I kill my destination it
In Akka we are using cassandra to persist data. Does Akka automatically
cleanup cassandra based on timestamp of messages or do we need to manually
(in code) do it? If so any pointers would be helpful.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
13 matches
Mail list logo
