On Wed, Jun 24, 2015 at 11:33 PM, Roberto Leibman robe...@leibman.net
wrote:
I tried to follow the documentation as close as possible. (
http://doc.akka.io/docs/akka-stream-and-http-experimental/current/scala/stream-integrations.html
)
I have an application that I want to wake up every 30
Hello,
I would to know if there is any documentation out there that will explain
how Akka-Streams uses Akka internally. I am curious about the
implementation of actors and how they communicate each other to compute the
different flows.
Thank you,
Héctor.
--
Read the docs:
ok thanks, this now works and the test runs in 5.5 secs. With
gossip-interval= 100 ms
it goes down to 4.5s
On 25/06/15 13:11, Patrik Nordwall wrote:
You can only join an existing cluster, and bootstrap by joining one to
itself.
for (c - allClusters) c.join(cluster1.selfAddress)
On Thu,
Thanks, gossip-interval works, but also tried 2.4-M1. I get a
compilation error that DistributedPubSubExtension is not found and can't
find DistributedPubSubExtension class in those deps:
http://search.maven.org/#search|ga|1|c%3A%22DistributedPubSubExtension%22
On 25/06/15 13:04, Patrik
On Tue, Jun 23, 2015 at 11:12 AM, Diego Martinoia diego.martin...@gmail.com
wrote:
Hi Patrick,
Thanks for your reply.
Cleaning all the metadata was the option I was thinking about too. I'm
just unsure whether there may be some race conditions between the wiping
out of the metadata and the
Glad to see that you are on track. In 2.4 you might find
registerOnMemberRemoved useful:
http://doc.akka.io/docs/akka/snapshot/scala/cluster-usage.html
Cheers,
Patrik
On Wed, Jun 24, 2015 at 6:11 PM, Anders Båtstrand ander...@gmail.com
wrote:
I have attached my logs showing the problem.
I do
Assume the following is the default mailbox:
akka.actor.default-mailbox.mailbox-type =
akka.dispatch.SingleConsumerOnlyUnboundedMailbox
On Thursday, June 25, 2015 at 2:20:01 PM UTC+1, Guido Medina wrote:
Hi,
I have an scenario where all messages come to a single main actor and such
Great work!
When will there be integration with cluster? Distribute workload of complex
streams to many nodes.
On Thursday, June 25, 2015 at 6:43:34 AM UTC-3, rkuhn wrote:
Dear hakkers,
we—the Akka committers—are pleased to announce the fourth release
candidate for Akka Streams HTTP. The
Hello there!
I am learning how to test remote actors in action and found the following
http://doc.akka.io/docs/akka/2.3.10/dev/multi-jvm-testing.html
http://doc.akka.io/docs/akka/2.3.11/dev/multi-node-testing.html
But they are talking that using sbt, you run these commands to run your
tests.
Hi Harit,
No, the multi-jvm plugin is developed mostly for our own needs, that is: for
testing Akka itself across many nodes.
We see other teams successfully using it as well, but no-one has really adapted
it to be usable from maven.
Myself having maintained (and still maintaining) a rather
Thanks Konrad, but I got confused, let me see if I understand
1. https://github.com/sbt/sbt-multi-jvmsbt-multi-jvm
https://github.com/sbt/sbt-multi-jvm is a sbt plugin that is used by
Akka team and others as well.
2. There is *no *maven plugin at the moment to test multi-jvm or
I understand.
Is there (or is it planned to be in the future) any (even convoluted) way
to recover without downtime in a production environment? Or is there any
way to write a journal plugin that may lead allow to recovering without
downtime?
Thanks,
D.
On Thursday, June 25, 2015 at 1:36:38
(I mean, in a sense during the corruption we already have a bit of
downtime, but this only prevents new instances to be created and
rebalanced, the old cluster will keep working and accepting requests, so
it's not technically a downtime)
Also on this topic: do you reckon that dumping a
No no, I take lot of time to understand simple things, it's a problem with
me ;-)
On Thu, Jun 25, 2015 at 2:26 PM, Konrad Malawski
konrad.malaw...@typesafe.com wrote:
Yes, correct.
Sorry if my wording was a bit confusing :-)
--
Cheers,
Konrad 'ktoso’ Malawski
Akka http://akka.io @
Should I design the import process by creating hundreds of
ProductPersistentActor (for each product in the CSV file) and keep a state
(and after a while destroy them all)? Will that fit the actor model?
I really don't want to do any ETL process for this. The importing process
should go through
My question is around the *PersistenceId* which need to be overridden in
every PersistentActor.
A persistent actor must have an identifier that doesn't change across
different actor incarnations. The identifier must be defined with the
persistenceId method.
I have an *OrderActor* which
Some time back I put together a simulator for a network service using the
akka IO pipelines (TcpPipelineHandler friends[1]) which takes care of the
framing aspects and just leaves you to deal with the messaging parsing
which from the sounds of it you already have. Unfortunately that akka
Ok, thanks, a Thread.sleep(2000) sorted it out. But now we go back to
the situation similar to my other post. How do I kickstart that
consistency. Currently my test waits all clusters to join and then
sleeps for 2 secs for the DistributedPubSub to become consistent. The
good news is all my
Hi Patrik,
On 23/06/15 08:07, Patrik Nordwall wrote:
Then I think you can reduce the
akka.cluster.seed-node-timeout = 2s
it improved things, currently the overal time to startup the cluster is
7 secs (it used to be 13)
It is 5 seconds by default.
I normally use the join command instead of
Dear hakkers,
we—the Akka committers—are pleased to announce the fourth release candidate for
Akka Streams HTTP. The most notable changes since 1.0-RC3 are:
One last big rename (yes, we are truly sorry about that): while the semantics
had evolved around it, we never adapted the name of the
20 matches
Mail list logo
