vember 2017 15:06:43 UTC+1, Martynas Mickevičius wrote:
>
> Hi,
>
> your approach sounds good. You can also have one parent supervisor actor,
> which when sees that all of its children has been stopped, would shut down
> the actor system itself.
>
>
>
> On Tue, Nov
Hello there.
I have a system that I would like to shutdown when all actors are
terminated. My system contains two supervisors with some of actors for each
of them.
The supervisors are watching their children an terminate themselves via a
*PoisonPill
*when there is no more children.
Some
Hi there,
I made an akka based tool that collect tasks from various sources and
publish them to one system. Mainly, I havd many 'collectors' that send a
`TaskFoundEvent` to an event bus. And one 'publisher' that create the task
on the target system. This tool should be executed on a
The beginning of the track will be done by a post-commit hook form our Git
server. However the build and static analysis don't have webhooks so I have
to poll them.
On Monday, 22 May 2017 16:11:26 UTC+2, gervais.b wrote:
>
> Hi there,
>
> I'm going to write a "*commit tracker*&
Hi there,
I'm going to write a "*commit tracker*" that will follow and a source code
commit from our Git server trough the build until the static analysis. The
goal is to display and update a message like "Commit xyz received, (delay)
and build succesfully, (delay) and incerase quality of 1%".
, rkuhn wrote:
>
> Yes, almost: it should be context.actorOf, not system.actorOf.
>
> Regards, Roland
>
> Sent from my iPhone
>
> On 3 Oct 2016, at 15:15, gervais.b <gerv...@gmail.com >
> wrote:
>
> Yes, sorry, state is good but per actor, so that I should
g = tagsByName.filter(line => line(1)==subject.name)(0)
activities.filter(line => line(0)==tag).foreach(report.add)
}
}
Is that okay ?
On Monday, 3 October 2016 14:37:39 UTC+2, rkuhn wrote:
>
>
> 3 okt. 2016 kl. 14:30 skrev gervais.b <gerv...@gmail.com >:
>
> Hello,
>
Hello,
I'm fairly new with Akka (and maybe the whole question below is polluted by
my synchronous background). In my app, I have to parse 2 CSV available as
HTTP, I plan to access them from one actor that accept two messages (one
per csv). But I should add another HTTP resources next week. So
