Re: [akka-user] How to restart a node?

2015-04-12 Thread Endre Varga
On Sat, Apr 11, 2015 at 1:36 AM, Andrey Ilinykh wrote: > Thank you! It works. But still there is a slim chance something goes wrong > (for example java process crashed). What a reason not to allow the same > actor system join multiple times? As far as I understand each actor system > has internal

Re: [akka-user] Is there any way in Akka-Streams (at all in Reactive Streams) to guarantee a message has been handled by "Sink"?

2015-04-12 Thread Endre Varga
Hi Reza, There is no acknowledgement support built-in to streams since they model a unidirectional stream and acknowledgements need a backchannel. To add that feature you need a backchannel, which means that the processing stages should be modeled as BidiFlows instead of Flows. That also means th

[akka-user] Is there any way in Akka-Streams (at all in Reactive Streams) to guarantee a message has been handled by "Sink"?

2015-04-12 Thread Reza Samee
Hello; Note: Please forgive me if I have mistake in English :) I would use akka-streams and reactive-rabbitmq to consuming/producing message from/to rabbitmq. In my problem I need a publisher (that in akka-streams would be an ActorProducer) that will be the "Source" of a flow to a "Sink" that pu

Re: [akka-user] How to restart a node?

2015-04-12 Thread Viktor Klang
The reason why it is not possible to rejoin is because other nodes have already acted upon the death of that node. Allowing the Undead in a cluster makes it really hard to reason about. On Sat, Apr 11, 2015 at 1:36 AM, Andrey Ilinykh wrote: > Thank you! It works. But still there is a slim chanc

[akka-user] Any simple example of akka-http and multipart/form-data

2015-04-12 Thread Fernando Romero
I want to upload pictures to an akka-http server. It would be very useful a simple example of this. I have experience using spray and play but I haven't used the new akka-http yet. Thanks in advance. -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>>

Re: [akka-user] How to restart a node?

2015-04-12 Thread Andrey Ilinykh
Thank you! It works. But still there is a slim chance something goes wrong (for example java process crashed). What a reason not to allow the same actor system join multiple times? As far as I understand each actor system has internal UUID which is generated every time you start akka. If some ho