[akka-user] Re: Setting SO_TIMEOUT in Akka I/O

OS closes it. Akka is not sending any message to indicate that the socket has been closed. Any ideas short of doing what Roiland suggested earlier? (i.e., modifying the protocol to periodically send some data). Thanks, -Mario. On Friday, December 27, 2013 9:26:46 PM UTC+1, Mario Camou wrote: &g

Re: [akka-user] Setting SO_TIMEOUT in Akka I/O

ess B is > an Akka application using IO actors. If that is right then there should > definitely be a ConnectionClosed event if at the time of the kill a TCP > connection was indeed established. > > Regards, > > Roland > > 26 aug 2014 kl. 21:17 skrev Mario Camou : > > Hi

Re: [akka-user] Setting SO_TIMEOUT in Akka I/O

pollMode). Are you >> certain that the socket is ready for reading when you make this test? >> > > Fair point, Roland. > > -Endre > > >> >> Regards, >> >> Roland >> >> 27 aug 2014 kl. 21:12 skrev Mario Camou : >> >> Hi Rol

[akka-user] Migrating data and stability with akka-persistence

Hi, We are currently evaluating persistence options for our backend. We are looking at akka-persistence but we have a couple of concerns: 1. How stable is the API now? Is it close enough to "final" that we could depend on it and not having to make code changes when 2.4 comes out? 2. How do we mi

Re: [akka-user] Migrating data and stability with akka-persistence

Thank you very much Konrad. That eases up my concerns. I read Roland's write-up and reply earlier today, but I was concerned about how stable the "write-side" is now. As to migration... there's a lot to read linked on that thread you linked to. Thanks! -Mario. -- I want to change the world but t

[akka-user] Setting SO_TIMEOUT in Akka I/O

Hi, I’m using Akka I/O and am trying to set the SO_TIMEOUT socket value. Looking at the docs, I see that the Tcp.Bind message receives a Traversable[SocketOption]. However, looking at the docs for akka.io.Inet.SocketOption, the only subclasses are Broadcast, KeepAlive, OOBInline, ReceiveBuffer

Re: [akka-user] Setting SO_TIMEOUT in Akka I/O

ome timeout in your protocol, you have to implement it yourself. > > -Endre > > > On Fri, Dec 27, 2013 at 9:26 PM, Mario Camou wrote: > Hi, > > I’m using Akka I/O and am trying to set the SO_TIMEOUT socket value. > > Looking at the docs, I see that the Tcp.Bind messag

Re: [akka-user] Setting SO_TIMEOUT in Akka I/O

f a > client silently going away, then you’ll have to look into SO_KEEPALIVE, but > check how to enable it in your operating system as well and if your client > supports that. > > Regards, > > Roland > > 2 jan 2014 kl. 11:44 skrev Mario Camou : > >> Hi Endre

[akka-user] Akka persistence, clustering and eventual consistency

Hi everyone, I'm in the process of thinking through a rewrite of parts of an application using Akka Persistence. After watching Endre's talk from ScalaDays (I was unable to attend the talk itself and the streaming only made me sadder about that) I was thinking, is there a plan to apply this sor

Re: [akka-user] Akka persistence, clustering and eventual consistency

dies. > > I know this is a bit different from the idea you are proposing, but this may > be easier to implement than synchronizing stores of multiple processors. > > > On Fri, Jul 4, 2014 at 7:01 PM, Mario Camou wrote: > Hi everyone, > > I'm in the process of thin