[akka-user] Akka Persistence journal size
Does a journal continue to grow in size forever, even if you're using snapshots? Presumably, once a snapshot is stored, the events preceding it are no longer needed. Are they kept? If so, is it possible to purge them? -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Akka Persistence journal size
Hi Dan! Event sourcing systems like to think in terms of "never delete anything”. It’s basically auditing for free as well as the power to replay and analyse the entire history of your application. In such systems snapshots are only used ot make recovery faster - not to drop the proceeding data, which is why we don’t automatically delete preceding events when a snapshot succeeds. You can delete them by reacting to a snapshot succcess by issuing an deleteMessages(toSequenceNr = lastseqnr). Hope this helps! — Konrad On 30 October 2014 at 09:23:44, Dan Ellis (d...@danellis.me) wrote: Does a journal continue to grow in size forever, even if you're using snapshots? Presumably, once a snapshot is stored, the events preceding it are no longer needed. Are they kept? If so, is it possible to purge them? -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] akka system "shut down" with no error in logs
Hi akka team, Thx for the fast reply! We do not have Await.result() calls. We do have some db calls, writing data to hbase, however it is in small parts (~20 records each write) and we have no more than 5-6 actors writing in parallel. We did 2 modifications: 1. We changed our internal scheduler to send heartbeat directly to log instead of sending heartbeat as message 2. We change our first in line actor to use PinnedDispacher instead of the default one. And yet a...It happened again, and when do we didn't not see any heartbeat logs anymore which indicate it is not dispatcher issue. Any idea? On Monday, October 27, 2014 12:38:27 PM UTC+2, Akka Team wrote: > > Hi Oren, > > > > On Mon, Oct 27, 2014 at 7:22 AM, Oren Razon > wrote: > >> Hi, >> I'm using akka 2.3.6 on a single node on Amazon m1.large instance. >> I'm using akka system as a cluster (see my configuration file below). >> My akka system include several parallel identical topologies. >> Each topology start with an actor that act as a MQTT client at front >> which send arrived massages after processing them to some other actors >> (some of them written in scala and some in java). >> When starting up the system everything seem to work well. >> But after a couple of hours (usually ~8-10 hours) it seem that the MQTT >> actor (the first in front) is still getting it's messages and work as >> expected, but when sending them to its followers nothing happened. I do not >> see dead letters, or any logging (applicative \ akka) that indicate >> something regarding the actors (all heartbeats are stopped). >> When looking in all my logs at debug level it seem that there was no >> error at all, and that this scenario happen to all my topologies at the >> exact same moment. >> >> Trying to debug it, we added an internal scheduler into the second actor >> in line (the one that get messages from the MQTT actor) which send a "Tick" >> message to himself every minute and print it. >> As long as the system work well we see these "tick" messages, but when >> the system is "down" we do not see anymore "tick" messages. >> >> > This suspiciously looks like the common case when a dispatcher becomes > stalled because blocking calls are consuming up all the threads in the > underlying thread-pool. Do you have any blocking calls, or long-running > computations in any of the receive blocks of your actors? Do you use > Await.result()? > > -Endre > > > >> >> >> -- >> >> 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 subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to akka-user+...@googlegroups.com . >> To post to this group, send email to akka...@googlegroups.com >> . >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Akka Team > Typesafe - The software stack for applications that scale > Blog: letitcrash.com > Twitter: @akkateam > -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] akka system "shut down" with no error in logs
Hi Oren, 1. We changed our internal scheduler to send heartbeat directly to log > instead of sending heartbeat as message > 2. We change our first in line actor to use PinnedDispacher instead of the > default one. > It should be the other way around, the actors doing the blocking calls should be on the PinnedDispatcher and the rest can run on the default one. If the blocking actors share the dispatcher with clustering for example it will just die. > > And yet a...It happened again, and when do we didn't not see any heartbeat > logs anymore which indicate it is not dispatcher issue. > If you use a scheduled task that does not send messages to actors, but for example prints to stdout, and still stops, then there is a different issue lurking there. If this is the case, and you verified it, then this is either a bug in the scheduler, or amazon virtual machines mess up CPU timers which is then an Amazon issue. -Endre > > Any idea? > > > On Monday, October 27, 2014 12:38:27 PM UTC+2, Akka Team wrote: >> >> Hi Oren, >> >> >> >> On Mon, Oct 27, 2014 at 7:22 AM, Oren Razon wrote: >> >>> Hi, >>> I'm using akka 2.3.6 on a single node on Amazon m1.large instance. >>> I'm using akka system as a cluster (see my configuration file below). >>> My akka system include several parallel identical topologies. >>> Each topology start with an actor that act as a MQTT client at front >>> which send arrived massages after processing them to some other actors >>> (some of them written in scala and some in java). >>> When starting up the system everything seem to work well. >>> But after a couple of hours (usually ~8-10 hours) it seem that the MQTT >>> actor (the first in front) is still getting it's messages and work as >>> expected, but when sending them to its followers nothing happened. I do not >>> see dead letters, or any logging (applicative \ akka) that indicate >>> something regarding the actors (all heartbeats are stopped). >>> When looking in all my logs at debug level it seem that there was no >>> error at all, and that this scenario happen to all my topologies at the >>> exact same moment. >>> >>> Trying to debug it, we added an internal scheduler into the second actor >>> in line (the one that get messages from the MQTT actor) which send a "Tick" >>> message to himself every minute and print it. >>> As long as the system work well we see these "tick" messages, but when >>> the system is "down" we do not see anymore "tick" messages. >>> >>> >> This suspiciously looks like the common case when a dispatcher becomes >> stalled because blocking calls are consuming up all the threads in the >> underlying thread-pool. Do you have any blocking calls, or long-running >> computations in any of the receive blocks of your actors? Do you use >> Await.result()? >> >> -Endre >> >> >> >>> >>> >>> -- >>> >> 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 subscribed to the Google >>> Groups "Akka User List" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to akka-user+...@googlegroups.com. >>> To post to this group, send email to akka...@googlegroups.com. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Akka Team >> Typesafe - The software stack for applications that scale >> Blog: letitcrash.com >> Twitter: @akkateam >> > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more
Re: [akka-user] Recomended cassandra and mongodb partners
Hi Diego, I don't know if there are commercially supported 3rd party journals. There is a list of contributions that you might want to look at: http://akka.io/community/ maybe some of them are supported. -Endre On Wed, Oct 29, 2014 at 5:34 PM, Diego Alvarez Zuluaga < diego.alvarez.zulu...@gmail.com> wrote: > Hello > > In my company we have plans to use akka-persistence. We need high > scalability and high availability, so that we plan to want to use cassandra > or mongo db. > > The people that are already using akka-persistence with any of this two > dbs can recommend us any partner that offer commercial support to cassandra > or mongo? > > We know that cassandra have this list, > http://wiki.apache.org/cassandra/ThirdPartySupport, but which partner can > you recommend us? > > Tks > > > > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Can Akka run without listening on a port?
Hi Bryn, On Wed, Oct 29, 2014 at 8:56 PM, Bryn Keller wrote: > Hi Folks, > > We have an application that needs to run in an environment where it is not > allowed to listen on any new sockets. It can connect to remote servers, but > it can't be a server itself. > > Is there any way to use Akka in that kind of environment to talk to an > Akka service on another machine? Perhaps make the "client" machine handle > both sides of the conversation by polling the "server" at regular intervals > or something? Anyone have any other ideas? > Akka Remoting does not support that, see here: http://doc.akka.io/docs/akka/2.3.6/general/remoting.html#Peer-to-Peer_vs__Client-Server This does not mean that you cannot use Akka in a Client-Server setup though, but you will need to implement your own client-server connection. This can be done over pure TCP using akka.io, but you can also make a REST endpoint using Spray server and client. -Endre > > Thanks, > Bryn > > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Stopping a reactive stream
Hi Adam, This might or might not be associated with the components of the stream > itself; in my current scenario I have a sink which is a reactive tcp > connection. > What do you mean by a reactive tcp connection here? Is it an Akka TCP stream? > I don't seem to be getting any errors (at least logged) by shutting down > the other side of the tcp connection, however I do get "outside" errors, > from the cluster/remoting watch - so I could use that to restart the whole > thing, if only I could make some "supervisor hierarchy" for the stream. > Streams have a built-in onComplete/cancel signal that is invoked when things terminate. Akka TCP provides those signals when the TCP connection goes away. I need to know more about the setup you have to see what is the problem. There was a problem though related to Windows that "connection reset by peer" events were lost, there is a bugfix/workaround pending for that, to be released with 2.3.7. If you are running Windows there is a high likeliness that you hit that bug. -Endre > > -- > Thanks, > Adam > > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Stopping a reactive stream
On Thursday, October 30, 2014 11:15:50 AM UTC+1, Akka Team wrote: > > Hi Adam, > > This might or might not be associated with the components of the stream >> itself; in my current scenario I have a sink which is a reactive tcp >> connection. >> > > What do you mean by a reactive tcp connection here? Is it an Akka TCP > stream? > Established using akka.stream.io.StreamTcp. > I don't seem to be getting any errors (at least logged) by shutting down >> the other side of the tcp connection, however I do get "outside" errors, >> from the cluster/remoting watch - so I could use that to restart the whole >> thing, if only I could make some "supervisor hierarchy" for the stream. >> > > Streams have a built-in onComplete/cancel signal that is invoked when > things terminate. Akka TCP provides those signals when the TCP connection > goes away. I need to know more about the setup you have to see what is the > problem. > > There was a problem though related to Windows that "connection reset by > peer" events were lost, there is a bugfix/workaround pending for that, to > be released with 2.3.7. If you are running Windows there is a high > likeliness that you hit that bug. > I'm not running Windows (MacOS), but how could these signals be handled? I was looking for some handlers in the value returned by run() (e.g. onComplete, onError), but it seems not much is there :) Thanks, Adam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Stopping a reactive stream
Hi Adam, > I'm not running Windows (MacOS), but how could these signals be handled? I > was looking for some handlers in the value returned by run() (e.g. > onComplete, onError), but it seems not much is there :) > Which version of Akka Stream are you using and which version of the scaladsl? How does your pipeline look like, what is the sink element (the thing in which you pipe TCP into). In general, a code snippet would help a lot. -Endre > > Thanks, > Adam > > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] akka system "shut down" with no error in logs
Hi Endre We did used the PinnedDispacher for the potential "blockers" but it still occurred. We use only log printing with the scheduling task (we didn't send any message), and it stopped. I don't think it's a scheduler specific bug cause it happen only when the BIG shutting down phenomena occur. What do you mean by "amazon virtual machines mess up CPU timers which is then an Amazon issue"? On Thursday, October 30, 2014 12:04:41 PM UTC+2, Akka Team wrote: > > Hi Oren, > > > > 1. We changed our internal scheduler to send heartbeat directly to log >> instead of sending heartbeat as message >> 2. We change our first in line actor to use PinnedDispacher instead of >> the default one. >> > > It should be the other way around, the actors doing the blocking calls > should be on the PinnedDispatcher and the rest can run on the default one. > If the blocking actors share the dispatcher with clustering for example it > will just die. > > >> >> And yet a...It happened again, and when do we didn't not see any >> heartbeat logs anymore which indicate it is not dispatcher issue. >> > > If you use a scheduled task that does not send messages to actors, but for > example prints to stdout, and still stops, then there is a different issue > lurking there. If this is the case, and you verified it, then this is > either a bug in the scheduler, or amazon virtual machines mess up CPU > timers which is then an Amazon issue. > > -Endre > > >> >> Any idea? >> >> >> On Monday, October 27, 2014 12:38:27 PM UTC+2, Akka Team wrote: >>> >>> Hi Oren, >>> >>> >>> >>> On Mon, Oct 27, 2014 at 7:22 AM, Oren Razon wrote: >>> Hi, I'm using akka 2.3.6 on a single node on Amazon m1.large instance. I'm using akka system as a cluster (see my configuration file below). My akka system include several parallel identical topologies. Each topology start with an actor that act as a MQTT client at front which send arrived massages after processing them to some other actors (some of them written in scala and some in java). When starting up the system everything seem to work well. But after a couple of hours (usually ~8-10 hours) it seem that the MQTT actor (the first in front) is still getting it's messages and work as expected, but when sending them to its followers nothing happened. I do not see dead letters, or any logging (applicative \ akka) that indicate something regarding the actors (all heartbeats are stopped). When looking in all my logs at debug level it seem that there was no error at all, and that this scenario happen to all my topologies at the exact same moment. Trying to debug it, we added an internal scheduler into the second actor in line (the one that get messages from the MQTT actor) which send a "Tick" message to himself every minute and print it. As long as the system work well we see these "tick" messages, but when the system is "down" we do not see anymore "tick" messages. >>> This suspiciously looks like the common case when a dispatcher becomes >>> stalled because blocking calls are consuming up all the threads in the >>> underlying thread-pool. Do you have any blocking calls, or long-running >>> computations in any of the receive blocks of your actors? Do you use >>> Await.result()? >>> >>> -Endre >>> >>> >>> -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+...@googlegroups.com. To post to this group, send email to akka...@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. >>> >>> >>> >>> -- >>> Akka Team >>> Typesafe - The software stack for applications that scale >>> Blog: letitcrash.com >>> Twitter: @akkateam >>> >> -- >> >> 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 subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to akka-user+...@googlegroups.com . >> To post to this group, send email to akka...@googlegroups.com >> . >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Akka Team > Typesafe - The software stack for applications
Re: [akka-user] Stopping a reactive stream
Sure :) I'm using streams 0.9, scaladsl2 and I want to add failure detection to that: https://github.com/adamw/reactmq/blob/master/src/main/scala/com/reactmq/Sender.scala Adam On Thursday, October 30, 2014 12:04:23 PM UTC+1, Akka Team wrote: > > Hi Adam, > > >> I'm not running Windows (MacOS), but how could these signals be handled? >> I was looking for some handlers in the value returned by run() (e.g. >> onComplete, onError), but it seems not much is there :) >> > > Which version of Akka Stream are you using and which version of the > scaladsl? How does your pipeline look like, what is the sink element (the > thing in which you pipe TCP into). > > In general, a code snippet would help a lot. > > -Endre > > >> >> Thanks, >> Adam >> >> -- >> >> 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 subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to akka-user+...@googlegroups.com . >> To post to this group, send email to akka...@googlegroups.com >> . >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Akka Team > Typesafe - The software stack for applications that scale > Blog: letitcrash.com > Twitter: @akkateam > -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Akka Persistence insights
Hello all, I have been looking into this library https://github.com/sclasen/akka-persistence-dynamodb/ and I got couple of questions both about the library and the Akka Persistence in general. One of the questions that I have is this: Is persistence counter going to ever reset? As far I understand sequence numbers are generated as "highest sequence number + 1", but isn't it going to overflow? Is there any mechanism to delete all messages and start counter from the beginning? -- Notice: This email is confidential and may contain copyright material of members of the Ocado Group. Opinions and views expressed in this message may not necessarily reflect the opinions and views of the members of the Ocado Group. If you are not the intended recipient, please notify us immediately and delete all copies of this message. Please note that it is your responsibility to scan this message for viruses. References to the “Ocado Group” are to Ocado Group plc (registered in England and Wales with number 7098618) and its subsidiary undertakings (as that expression is defined in the Companies Act 2006) from time to time. The registered office of Ocado Group plc is Titan Court, 3 Bishops Square, Hatfield Business Park, Hatfield, Herts. AL10 9NE. -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Akka Persistence insights
Hi Saparbek, If sequenceNr is a Long (64-bit) you'd have to generate 1 event per nanosecond for 292 years before it overflows. If your system is still running in 292 years and you are able to generate 1 event per nanosecond, let us know :) On Thu, Oct 30, 2014 at 12:48 PM, Saparbek Smailov wrote: > Hello all, > > I have been looking into this library > https://github.com/sclasen/akka-persistence-dynamodb/ and I got couple of > questions both about the library and the Akka Persistence in general. > One of the questions that I have is this: > Is persistence counter going to ever reset? As far I understand sequence > numbers are generated as "highest sequence number + 1", but isn't it going > to overflow? Is there any mechanism to delete all messages and start > counter from the beginning? > > > Notice: This email is confidential and may contain copyright material of > members of the Ocado Group. Opinions and views expressed in this message > may not necessarily reflect the opinions and views of the members of the > Ocado Group. > > If you are not the intended recipient, please notify us immediately and > delete all copies of this message. Please note that it is your > responsibility to scan this message for viruses. > > References to the “Ocado Group” are to Ocado Group plc (registered in > England and Wales with number 7098618) and its subsidiary undertakings (as > that expression is defined in the Companies Act 2006) from time to time. > The registered office of Ocado Group plc is Titan Court, 3 Bishops Square, > Hatfield Business Park, Hatfield, Herts. AL10 9NE. > > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Cheers, √ -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Recomended cassandra and mongodb partners
Journals I guess no, but if you need support then both typesafe offer it for the akka part of your system and each database vendor does so for their database. Cassandra being a Datastax supported thing, mongo do their own support etc. So seems like that’s what you may have to look into? — k On 30 October 2014 at 11:09:23, Akka Team (akka.offic...@gmail.com) wrote: Hi Diego, I don't know if there are commercially supported 3rd party journals. There is a list of contributions that you might want to look at: http://akka.io/community/ maybe some of them are supported. -Endre On Wed, Oct 29, 2014 at 5:34 PM, Diego Alvarez Zuluaga wrote: Hello In my company we have plans to use akka-persistence. We need high scalability and high availability, so that we plan to want to use cassandra or mongo db. The people that are already using akka-persistence with any of this two dbs can recommend us any partner that offer commercial support to cassandra or mongo? We know that cassandra have this list, http://wiki.apache.org/cassandra/ThirdPartySupport, but which partner can you recommend us? Tks -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. -- Konrad 'ktoso' Malawski hAkker @ typesafe http://akka.io -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Stopping a reactive stream
Hi Adam, You can use broadcast to split out the stream going into the Sink, and then attach to that side of the graph an OnCompleteSink which takes a function callback: Try[Unit] ⇒ Unit which is called during normal and failure termination. -Endre On Thu, Oct 30, 2014 at 12:31 PM, Adam Warski wrote: > Sure :) I'm using streams 0.9, scaladsl2 and I want to add failure > detection to that: > > > https://github.com/adamw/reactmq/blob/master/src/main/scala/com/reactmq/Sender.scala > > Adam > > On Thursday, October 30, 2014 12:04:23 PM UTC+1, Akka Team wrote: >> >> Hi Adam, >> >> >>> I'm not running Windows (MacOS), but how could these signals be handled? >>> I was looking for some handlers in the value returned by run() (e.g. >>> onComplete, onError), but it seems not much is there :) >>> >> >> Which version of Akka Stream are you using and which version of the >> scaladsl? How does your pipeline look like, what is the sink element (the >> thing in which you pipe TCP into). >> >> In general, a code snippet would help a lot. >> >> -Endre >> >> >>> >>> Thanks, >>> Adam >>> >>> -- >>> >> 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 subscribed to the Google >>> Groups "Akka User List" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to akka-user+...@googlegroups.com. >>> To post to this group, send email to akka...@googlegroups.com. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Akka Team >> Typesafe - The software stack for applications that scale >> Blog: letitcrash.com >> Twitter: @akkateam >> > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+unsubscr...@googlegroups.com. > To post to this group, send email to akka-user@googlegroups.com. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - The software stack for applications that scale Blog: letitcrash.com Twitter: @akkateam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Stopping a reactive stream
There's an OnCompleteDrain :) (btw. - sink, drain, subscriber - a lot of names ;) ) How do I use broadcast, thought? I can see it can be a vertex in the graph, but how to add it? So I'll end up with sth like this: /---> sink1 (output stream) source --> trans1 --> broadcast --< \---> sink2 (on complete drain) Will the failure of sink1 propagate to a completion of the whole stream? In theory it could continue in a "crippled" way (with only one branch remaining). Thanks! Adam On Thursday, October 30, 2014 1:22:41 PM UTC+1, Akka Team wrote: > > Hi Adam, > > You can use broadcast to split out the stream going into the Sink, and > then attach to that side of the graph an OnCompleteSink which takes a > function callback: Try[Unit] ⇒ Unit which is called during normal and > failure termination. > > -Endre > > On Thu, Oct 30, 2014 at 12:31 PM, Adam Warski > wrote: > >> Sure :) I'm using streams 0.9, scaladsl2 and I want to add failure >> detection to that: >> >> >> https://github.com/adamw/reactmq/blob/master/src/main/scala/com/reactmq/Sender.scala >> >> Adam >> >> On Thursday, October 30, 2014 12:04:23 PM UTC+1, Akka Team wrote: >>> >>> Hi Adam, >>> >>> I'm not running Windows (MacOS), but how could these signals be handled? I was looking for some handlers in the value returned by run() (e.g. onComplete, onError), but it seems not much is there :) >>> >>> Which version of Akka Stream are you using and which version of the >>> scaladsl? How does your pipeline look like, what is the sink element (the >>> thing in which you pipe TCP into). >>> >>> In general, a code snippet would help a lot. >>> >>> -Endre >>> >>> Thanks, Adam -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+...@googlegroups.com. To post to this group, send email to akka...@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout. >>> >>> >>> >>> -- >>> Akka Team >>> Typesafe - The software stack for applications that scale >>> Blog: letitcrash.com >>> Twitter: @akkateam >>> >> -- >> >> 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 subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to akka-user+...@googlegroups.com . >> To post to this group, send email to akka...@googlegroups.com >> . >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Akka Team > Typesafe - The software stack for applications that scale > Blog: letitcrash.com > Twitter: @akkateam > -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Akka Persistence journal size
> You can delete them by reacting to a snapshot succcess by issuing an > deleteMessages(toSequenceNr = lastseqnr). If I only care about recovery and not auditing, are there any disadvantages to doing that? Would it be considered an anti-pattern? I'm just evaluating and considering my options at the moment -- I don't know that space will be an issue. -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Can Akka run without listening on a port?
Thanks, Endre. I'm not quite clear on what you're saying - I understand Akka wants to work in peer-to-peer mode, but I don't understand this part: This does not mean that you cannot use Akka in a Client-Server setup >> though, but you will need to implement your own client-server connection. >> This can be done over pure TCP using akka.io, but you can also make a >> REST endpoint using Spray server and client. >> > Are you saying that Akka *can* work client-server if I implement some class or classes myself and configure Akka to use it/them, or are you saying that I can't use Akka for communication between client and server in this scenario at all (other than Akka I/O, which is not what I'm asking about)? If I need to implement some custom transport for Akka myself, how would I go about that? "Akka custom transport" doesn't produce much in a Google search, are there some other resources? To be clear, I have an existing third party application that uses Akka actor systems for remote communication, so I would prefer a solution that lets me simply configure Akka to use some custom built components rather than having to completely change the interface between client and server. Is this possible? Thanks, Bryn -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Recomended cassandra and mongodb partners
Ok thanks. We already have TypeSafe Support. We're looking for (Cassandra, MongoDB) Commercial Support. I sent a email to all of the companies that are listed in the Cassandra Wiki, but so far I just received a response from DataStax. Does TypeSafe/akka-team have any recommendation on using Cassandra or Mongodb with akka-persistence? Tks *--* *Diego Álvarez Zuluaga* On Thursday, October 30, 2014 6:57:21 AM UTC-5, Konrad Malawski wrote: > > Journals I guess no, but if you need support then both typesafe offer it > for the akka part of your system and each database vendor does so for their > database. > Cassandra being a Datastax supported thing, mongo do their own support > etc. So seems like that’s what you may have to look into? > > — k > > On 30 October 2014 at 11:09:23, Akka Team (akka.o...@gmail.com > ) wrote: > Hi Diego, > > I don't know if there are commercially supported 3rd party journals. There > is a list of contributions that you might want to look at: > http://akka.io/community/ maybe some of them are supported. > > -Endre > > On Wed, Oct 29, 2014 at 5:34 PM, Diego Alvarez Zuluaga < > diego.alva...@gmail.com > wrote: > >> Hello >> >> In my company we have plans to use akka-persistence. We need high >> scalability and high availability, so that we plan to want to use cassandra >> or mongo db. >> >> The people that are already using akka-persistence with any of this two >> dbs can recommend us any partner that offer commercial support to cassandra >> or mongo? >> >> We know that cassandra have this list, >> http://wiki.apache.org/cassandra/ThirdPartySupport, but which partner >> can you recommend us? >> >> Tks >> >> >> >> -- >> >> 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 subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to akka-user+...@googlegroups.com . >> To post to this group, send email to akka...@googlegroups.com >> . >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > > > -- > Akka Team > Typesafe - The software stack for applications that scale > Blog: letitcrash.com > Twitter: @akkateam > -- > >> 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 subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to akka-user+...@googlegroups.com . > To post to this group, send email to akka...@googlegroups.com > . > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- > Konrad 'ktoso' Malawski > hAkker @ typesafe > http://akka.io > -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
Re: [akka-user] Recomended cassandra and mongodb partners
Personally I'd rather using Cassandra because is not a SPOF like the master-slave architecture that mongodb has. But I've no experience with any of those databases :/ On Thursday, October 30, 2014 2:49:36 PM UTC-5, Diego Alvarez Zuluaga wrote: > > Ok thanks. > > We already have TypeSafe Support. We're looking for (Cassandra, MongoDB) > Commercial Support. > > I sent a email to all of the companies that are listed in the Cassandra > Wiki, but so far I just received a response from DataStax. > > Does TypeSafe/akka-team have any recommendation on using Cassandra or > Mongodb with akka-persistence? > > Tks > > *--* > > *Diego Álvarez Zuluaga* > > > On Thursday, October 30, 2014 6:57:21 AM UTC-5, Konrad Malawski wrote: >> >> Journals I guess no, but if you need support then both typesafe offer it >> for the akka part of your system and each database vendor does so for their >> database. >> Cassandra being a Datastax supported thing, mongo do their own support >> etc. So seems like that’s what you may have to look into? >> >> — k >> >> On 30 October 2014 at 11:09:23, Akka Team (akka.o...@gmail.com) wrote: >> Hi Diego, >> >> I don't know if there are commercially supported 3rd party journals. >> There is a list of contributions that you might want to look at: >> http://akka.io/community/ maybe some of them are supported. >> >> -Endre >> >> On Wed, Oct 29, 2014 at 5:34 PM, Diego Alvarez Zuluaga < >> diego.alva...@gmail.com> wrote: >> >>> Hello >>> >>> In my company we have plans to use akka-persistence. We need high >>> scalability and high availability, so that we plan to want to use cassandra >>> or mongo db. >>> >>> The people that are already using akka-persistence with any of this two >>> dbs can recommend us any partner that offer commercial support to cassandra >>> or mongo? >>> >>> We know that cassandra have this list, >>> http://wiki.apache.org/cassandra/ThirdPartySupport, but which partner >>> can you recommend us? >>> >>> Tks >>> >>> >>> >>> -- >>> >> 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 subscribed to the Google >>> Groups "Akka User List" group. >>> To unsubscribe from this group and stop receiving emails from it, send >>> an email to akka-user+...@googlegroups.com. >>> To post to this group, send email to akka...@googlegroups.com. >>> Visit this group at http://groups.google.com/group/akka-user. >>> For more options, visit https://groups.google.com/d/optout. >>> >> >> >> >> -- >> Akka Team >> Typesafe - The software stack for applications that scale >> Blog: letitcrash.com >> Twitter: @akkateam >> -- >> >> 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 subscribed to the Google Groups >> "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send an >> email to akka-user+...@googlegroups.com. >> To post to this group, send email to akka...@googlegroups.com. >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> -- >> Konrad 'ktoso' Malawski >> hAkker @ typesafe >> http://akka.io >> > -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
[akka-user] Best way to integrate akka into a legacy/existing app
Hello everybody, I want to add Akka to an existing scala web application (not play), and I'm wondering how it could be best achieve. The goal for now is not to build a fully distributed and fault tolerant system, but to introduce Akka at some point in the application and let its use grow, allowing to set clear bound in that application and define subsystems. A nice and solution would be to have a new application in Akka side by side with the legacy one, providing new services or REST endpoint or something. But I prefer to not investigate that solution for now and try to understand how Akka can be incorporated into an existing app. I'm particulary intersted into knowing how 1/ Akka boot in that case and 2/ how to deals with the bound between actors and legacy code. For 1/, http://doc.akka.io/docs/akka/1.3.1/scala/http.html seems to be the correct resources. Is there other example or documentation on the subject ? (I didn't find many other intersting one, any help would be appreciated). For 2/, let me start by saying that I have two places where I want to use akka at first: some kind of batch processes, which are more or less standalone (and so, not very interesting), and "repository", or at least the proxy code between backend data storage base and the remaining code. So, at one point, I imagine having an actor at the place of the existing repository service, accepting messages in place of method calls. But I don't see how to do that. I thought it could be linked to http://doc.akka.io/docs/akka/2.3.6/scala/typed-actors.html. Is it correct ? If so, is there any ressources demoing a more complexe integration ? Because I'm not sure how I implement my actor subsystem from the typed actor boundaries with the legacy app. Thanks for any help or pointer to ressources ! -- Francois ARMAND http://rudder-project.org http://www.normation.com -- >> 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 subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
