[akka-user] akka (actor typed actors) cluster, 2 nodes in same jvm, they don't join the cluster

I've created an akka cluster with this config on node 1 (flattened): akka.cluster.roles : [ "distmem-server" ] akka.logging-filter : "akka.event.slf4j.Slf4jLoggingFilter" akka.remote.netty.tcp.hostname : "distmem.lan"* <--- this exists in my hosts file and points to localhost, but tried

Re: [akka-user] Akka Actor usage in Apache Spark and Apache Flink

Another pretty big Akka based project (as in, really using Akka a lot) is Apache OpenWhisk, the open source "amazon lambda"; Check it out as well. https://github.com/apache?q=openwhisk On Mon, Feb 19, 2018 at 2:32 PM, Konrad “ktoso” Malawski < konrad.malaw...@lightbend.com> wrote: > Best to ask

Re: [akka-user] Akka Actor usage in Apache Spark and Apache Flink

Best to ask on a Flink forum ;-) -- Cheers, Konrad 'ktoso ' Malawski Akka @ Lightbend On February 19, 2018 at 14:32:15, Unmesh Joshi (unmeshjo...@gmail.com) wrote: Thanks Konrad. What I was interested in was what use cases both Spark and

Re: [akka-user] Akka Actor usage in Apache Spark and Apache Flink

Thanks for sharing. Trying to find and understand the use cases where Actors are used in other open source projects. On Mon, Feb 19, 2018 at 11:04 AM, Konrad Malawski < konrad.malaw...@lightbend.com> wrote: > Another pretty big Akka based project (as in, really using Akka a lot) is > Apache

Re: [akka-user] Akka Actor usage in Apache Spark and Apache Flink

Thanks Konrad. What I was interested in was what use cases both Spark and Flink used Actors for specifically. Are there any notes/docs around those that anyone knows of? On Monday, 19 February 2018 07:33:43 UTC+5:30, Konrad Malawski wrote: > > Hi there, > There's been some confusion about how

Re: [akka-user] Akka Actor usage in Apache Spark and Apache Flink

Hi there, There's been some confusion about how Spark used Akka, so let's clear that up first: It wasn't really core to any of the operations or core of Spark, and was used only to orchestrate some things, it was using raw Akka Remoting (which is discouraged, use Cluster instead due to the

[akka-user] Akka Actor usage in Apache Spark and Apache Flink

Hi, Apache Spark used to use Akka Actors (which is replaced by Netty now) and Apache Flink uses Actors. I am trying to understand the use case of Actor usage in both these frameworks. Any pointers for help? Thanks, Unmesh -- >> Read the docs: http://akka.io/docs/ >>

Re: [akka-user] Akka actor wait on future to resolve before taking off mailbox

You need to slow down the producer, because otherwise messages will fill up mailboxes (if you use await) or buffers (if you use stash) eventually resulting in out of memory. I don't think a router is the right tool here. I would implement this with an ordinary actor that delegates to the doWork

Re: [akka-user] Akka actor wait on future to resolve before taking off mailbox

I suspect you're looking for stash(), which is the usual answer to "I want to pause my inbox for a bit"... On Thu, Mar 23, 2017 at 8:47 PM, Sean Callahan wrote: > Hey all. Ive got an Actor set up that when called, takes a little bit of > time to run and I want to

[akka-user] Akka actor wait on future to resolve before taking off mailbox

Hey all. Ive got an Actor set up that when called, takes a little bit of time to run and I want to limit how many "runs" happen at the same time. I have a routing pool above this actor to accomplish that. However, in my current implementation of the actor I am blocking to get that

Re: [akka-user] Akka Actor

Sure I did have a Progress Message via the main actor which call to the workerActor to return current progress, but the user is able to call the endpoint over and over again, that meaning I need some indicator whether the actor has finished or still running. More or less like this schema..

Re: [akka-user] Akka Actor

Sure, but there's nothing built in -- you'd have to roll something yourself. The most obvious way to do it is to add a Progress message, which the outside system strobes to mainActor, say, once a second, and which mainActor responds with the current state of the processing. (I do a much more

[akka-user] Akka Actor

Currently I have rest-endpoint-api-playframework that contains main actor to run n number of worker-actors doing batch-insertion. while in the process of doing that, I'd love to get current process of the inserts, lets say 100/1000. in order to do that, obviously I'll have the actor to report

[akka-user] akka actor tcp and how to wait for received msg before writing again

I'm learning about akka tcp using actors in scala and I would like to write a bytestring to a connection to a remote host, and wait until I receive a msg reply. I need to do this in order to not overflow the server with my client. Can someone help me write an actor that can write and wait for

[akka-user] Akka Actor Hierarchy Question

Hello all, I'm playing around with Akka in conjunction with the Play framework, working in Java. I have a reasonable understanding of how the actor system works in general, but I need some help wrapping my head around how to set up the system efficiently. Let's take the Chat server example.

Re: [akka-user] [akka-actor] ActorSystem Singleton Database Connection

Thanks. It would really works that way. On the other hand its a kind of awkward workaround. I already have the configured connection context object at hand. I get it via dependency injection and would like to pass it to the extension or actor system directly. Since I cannot pass objects of

[akka-user] [akka-actor] ActorSystem Singleton Database Connection

Hello, my actor based application needs access to exactly one database per actor system. I look for a way to attach a singleton database connection object to the actor system. I'm looking for a kind of type safe and immutable servlet context like approach. First I thought about Extension's.

Re: [akka-user] [akka-actor] ActorSystem Singleton Database Connection

Have you considered implementing your connection as an extension but using different configurations for the different systems? http://doc.akka.io/docs/akka/current/general/configuration.html On Wed, Jan 27, 2016 at 11:55 AM, wrote: > Hello, > my actor based

[akka-user] Akka Actor garbage collected?

Hello, I have a UI Controller that listens to requests from the user, and uses Akka to talk to some other back end services for request processing. When I bootstrap my UI, I wire in an ActorSystem object. When I receive a request from a user, I create an "actor-per-request" using the wired

[akka-user] Akka actor creation with service dependencies on a random node in a cluster

Hi, I am new to akka. I have posted the question on stackoverflow: This relates to Create actor on any unspecified/random node in cluster http://stackoverflow.com/questions/22802740/create-actor-on-any-unspecified-random-node-in-cluster . I am new to akka. I looking at using akka 2.3.12 but

[akka-user] akka actor - performance issue

Hi everyone! I working on some scala computing some game theory problem using Akka. Basically I've got three types involved : 1. ComputingActor - does the job, running 1 actor for 1 experiment 2. ResultsActor - collects results from computing actors and sends to JobScheduler when job's done 3.

Re: [akka-user] Akka actor as mailer and message attachments

On 04/19/15 13:38, Erol Merdanović wrote: Hi I have created a simple NotificationActor which receives 2 types of message: EmailMessage and MobileTextMessage. Main goal of the actor is to call the external services and send an email or text message. Everything works, but now I want to handle

[akka-user] Akka actor as mailer and message attachments

Hi I have created a simple NotificationActor which receives 2 types of message: EmailMessage and MobileTextMessage. Main goal of the actor is to call the external services and send an email or text message. Everything works, but now I want to handle attachments. Attachments can be up to 5MB.

[akka-user] Akka actor creation

Hi All, I am new to akka. I went through some of the videos of Jones Boner. He says that in 1GB of RAM, we can create several thousands of threads. But, with Akka, we can create several millions of actors. If I am not wrong, actors internally create threads (fork-join threads). Then, how is

Re: [akka-user] Akka Actor Per Request Java Sample

Thanks for sharing! 28 jul 2014 kl. 19:10 skrev John Haigh haig...@gmail.com: Further to this I created a sample at https://github.com/haighis/java-jersey-akka-backend-actor. This is written entirely in Java and is based on the sample at https://github.com/pofallon/jersey2-akka-java.

[akka-user] Akka Actor Per Request Java Sample

Hello, I have seen the Scala Actor Per Request sample at https://github.com/NET-A-PORTER/spray-actor-per-request, and I am wondering if there is a Java version out there in some form? I found the following java REST samples but I want to understand what the best method for implementation

Re: [akka-user] Akka Actor Per Request Java Sample

At least some of this code is necessarily in Scala as Spray does not support Java. You could likely get some of this working (or something approximating it) with the new akka-http module, but it does not yet have an equivalent for spray-routing, so you would have to manually handle the route

[akka-user] Akka Actor cleans its state unexpectedly

Hi Guys, could you look at this. Maybe it is a bug or I missed something ? I have thishttps://github.com/Sergey80/akka-samples/blob/master/src/main/java/s2_example/actors/AggregateWordCountActor.java actor that is involved in *parallel-word-count-calculation*. It has a state: private

[akka-user] Akka actor cannot be resolved with actorSelection

We are trying something unconventional. We are trying to use Akka library inside Android. This has already been testes with success in the past and It all played well for us so far. Unfortunately we are stumbled across this issue: Akka actor cannot be resolved with actorSelection when used