[akka-user] Re: What is the different between a typed actor and a normal object wrapping an actor instance?

Seems like there is Typed Actors and Actor Typed. Since Type Actors is being depreciated, my question is aimed at Actor Typed instead. On Wednesday, April 6, 2016 at 11:41:37 AM UTC+8, Lap Ming Lee wrote: > > Hi, > > I am reading up on Typed Actors and it seems like its only recommended to

[akka-user] How do you determine/set the version of Akka used by the Scala REPL?

I am running MacOSX10.8, Java1.8, Scala 2.11 and would like to run Akka 2.4 in the Scala REPL, but I cannot find out how to specific where the Scala REPL gets its Akka implementation. I can run simple Akka actors in the REPL, but more advanced topics (like remote applications) generate errors

Re: [akka-user] Re: Akka Persistence with Cassandra

Hi, If I use below application.conf (default settings). akka { persistence { journal.plugin="cassandra-journal" snapshot-store.plugin="cassandra-snapshot-store" } } I got below exception Starting SLF4J: Failed to load class

Re: [akka-user] ANNOUNCE: Akka 2.4.3 released!

I'll wait. Looking at that ScalaDoc, I have no idea whatsoever how to use it :) On Tue, Apr 5, 2016 at 3:19 PM, Konrad Malawski wrote: > Please refer to it's scala doc for the time being: > http://doc.akka.io/api/akka/2.4.3/#akka.stream.KillSwitches$ > > -- > Cheers, >

[akka-user] [akka-streams] Resource pool for use within a flow

I can't figure out a clean way to implement something like the following with akka-streams: 1. Pull work item from a large-but-finite queue 2. Wait for a resource to be available from a small and finite pool [blocking, so probably evil?] 3. Do a computation using work item and resource.

Re: [akka-user] ANNOUNCE: Akka 2.4.3 released!

Please refer to it's scala doc for the time being:  http://doc.akka.io/api/akka/2.4.3/#akka.stream.KillSwitches$ --  Cheers, Konrad 'ktoso’ Malawski Akka @ Lightbend -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Dstributing data in akka cluster (guidance needed)

HI, I am looking for guidance, if anyway is willing to share their experience: I have an akka distributed system where I want to store small amounts of data (basically tombstones and other assorted bits). They may be stored on one node and consumed on another at a later time if the connection

Re: [akka-user] Re: Cloud Foundry + AKKA Cluster

thank you Patrick. On Tuesday, April 5, 2016 at 2:15:53 PM UTC-5, Patrik Nordwall wrote: > > 127.0.0.1 will only work on one machine (localhost). > Read more: > http://doc.akka.io/docs/akka/2.4.3/java/cluster-usage.html#Joining_to_Seed_Nodes > tis 5 apr. 2016 kl. 20:48 skrev Yan Pei

Re: [akka-user] ANNOUNCE: Akka 2.4.3 released!

Thank you. The divide by zero fix to throttle has already helped me. I'm not seeing any documentation for KillSwitch. Did I miss it? On Mon, Apr 4, 2016 at 1:08 PM, Justin du coeur wrote: > +1, with a particular thank-you for the more-transparent process. Being > able to

Re: [akka-user] Re: Cloud Foundry + AKKA Cluster

127.0.0.1 will only work on one machine (localhost). Read more: http://doc.akka.io/docs/akka/2.4.3/java/cluster-usage.html#Joining_to_Seed_Nodes tis 5 apr. 2016 kl. 20:48 skrev Yan Pei : > Thank you Patrick for the hints. other team set up Cassandra in CF. I will > ask them and

Re: [akka-user] Re: Cloud Foundry + AKKA Cluster

Thank you Patrick for the hints. other team set up Cassandra in CF. I will ask them and give update if I get anything useful. Could you please clarify this to me: remote { #log-remote-lifecycle-events = on # if off then they are not logged #log-sent-messages = on # if

Re: [akka-user] Akka HTTP bind exception on Windows

Hi, I think SO_REUSEADDR is enabled by default for Akka HTTP. At least it looks like that when I looked at the code. But even if it is disabled, the OS should not need ten minutes to release the socket. Maybe I write a simple test program tomorrow that demonstrates the problem. My problem

Re: [akka-user] Re: Cloud Foundry + AKKA Cluster

I have heard that you can run Cassandra in CF. i think you would need a similar solution for Akka seed nodes as how Cassandra contact points are handled in CF. If someone has a better answer or knows how Cassandra in CF works I would also be curious to know. /Patrik tis 5 apr. 2016 kl. 18:12

[akka-user] Behavior of akka 2.4.3 with modeled custom headers

So I have some custom modeled headers, with one of them being defined like so: object `X-Access-Token` extends ModeledCustomHeaderCompanion[`X-Access-Token`]{ override val name = "X-Access-Token" override def parse(value:String) = util.Try(`X-Access-Token`(value)) } case class

Re: [akka-user] Akka HTTP bind exception on Windows

Have you tried to add a configuration (ServerSettings) when you bind the TCP which enables the ReuseAddress ( http://doc.akka.io/api/akka/2.4.3/#akka.io.Inet$$SO$$ReuseAddress) option? -Endre On Tue, Apr 5, 2016 at 6:29 PM, Endre Varga wrote: > But that code uses

Re: [akka-user] Akka HTTP bind exception on Windows

But that code uses SO_REUSEADDR. -Endre On Tue, Apr 5, 2016 at 5:50 PM, Michi wrote: > Hi Endre, > > I wrote a small test program that creates a socket channel, closes it and > creates another one using the same port: > > import java.io.IOException; >

[akka-user] Re: Cloud Foundry + AKKA Cluster

The problem we are facing right now is how to get the IP for node instance running inside CF since the IP is dynamically generated. Another question: is it possible to run Actor instance in difference node? for example: final Config config =

Re: [akka-user] Akka HTTP bind exception on Windows

[forget the last paragraph, found the answer in the first post] > 5 apr 2016 kl. 18:00 skrev Roland Kuhn : > >> >> 5 apr 2016 kl. 17:50 skrev Michi > >: >> >> Hi Endre, >> >> I wrote a

Re: [akka-user] Akka HTTP bind exception on Windows

> 5 apr 2016 kl. 17:50 skrev Michi : > > Hi Endre, > > I wrote a small test program that creates a socket channel, closes it and > creates another one using the same port: > > import java.io.IOException; > import java.net.InetSocketAddress; > import

Re: [akka-user] Akka HTTP bind exception on Windows

Hi Endre, I wrote a small test program that creates a socket channel, closes it and creates another one using the same port: import java.io.IOException; import java.net.InetSocketAddress; import java.net.SocketAddress; import java.net.StandardSocketOptions; import

Re: [akka-user] Akka HTTP bind exception on Windows

On Tue, Apr 5, 2016 at 5:04 PM, Michi wrote: > Hi Endre, > > even after 10 Minutes TCPView shows that the socket is still bound by > jawaw.exe. If I close the application, the socket gets unbound immediately. > That's why I am wondering if I do something

Re: [akka-user] Akka HTTP bind exception on Windows

Hi Endre, even after 10 Minutes TCPView shows that the socket is still bound by jawaw.exe. If I close the application, the socket gets unbound immediately. That's why I am wondering if I do something wrong or if this is a bug in Akka HTTP. I tried to use a independent Actor System for the

Re: [akka-user] Akka 2.4.3 cannot read response body when using http 1.0 request

Let's continue the discussion in the ticket. As Viktor found, it'd seem the 1.0 spec simply does not support this though...? On Tue, Apr 5, 2016 at 2:29 PM, xiaog zh wrote: > https://github.com/akka/akka/issues/20236 > > Can somebody give me a little clue or even guide me

Re: [akka-user] Akka 2.4.3 cannot read response body when using http 1.0 request

https://github.com/akka/akka/issues/20236 Can somebody give me a little clue or even guide me get this problem fixed? On Tuesday, April 5, 2016 at 6:14:30 PM UTC+8, André wrote: > > The mandatory connection closing in HTTP 1.0 doesn't seem to work with > non-strict entities. > >

Re: [akka-user] Akka HTTP bind exception on Windows

Hi, As far as I know event though NIO reports the unbind, unbinding on Windows is not immediate and you are not guaranteed to be able to bind again immediately. I don't know if this comes from Windows or the NIO windows drivers though. -Endre On Tue, Apr 5, 2016 at 2:05 PM, Michi

[akka-user] Akka HTTP bind exception on Windows

Hi, we have a problem with Akka HTTP on Windows: after creating a server binding and unbinding it, it is not possible to bind it again. We get a akka.stream.BindFailedException. On Linux, this works without problems. The application uses the following code to create the server binding:

Re: [akka-user] Scheduler onReceive method called twice in a row but registered once

Hi, Akka 2.2 is an ancient version, almost 3 years old and it is not supported at all. 2.2.5 is the last version of that line. If you want support for these versions you need commercial support subscription. -Endre On Tue, Apr 5, 2016 at 12:35 PM, Aurélien Panhaleux wrote:

[akka-user] Scheduler onReceive method called twice in a row but registered once

Hello, I use akka (v2.2) over Play Framework (v2.2.6). I have a scheduler programmed to be executed each day at 8am. Everything was working fine, until one day to come where one of my scheduler became to be triggered twice in a row. The calls are separated by 1 millisecond, you can see logs of

Re: [akka-user] Dispatcher for ClientResponseTunnel

A tunnel is created for each sender, and when you ask it will be a different sender for each request. The tunnel actors will by default be stopped after 30 seconds of inactivity. When you use ask you should probably reduce this timeout to be similar to your ask timeout, a few seconds. ```

[akka-user] Akka 2.4.3 cannot read response body when using http 1.0 request

Hi, Below is a whole unit test in my project, and it fails when using `HTTP/1.0` protocol, success when using `HTTP/1.1`. Can somebody help explain the reason? // setup mock server val json = """ |{"result":true} """.stripMargin val source = Source(ByteString(json) :: Nil) val