akka Questions

3

Solved

I am trying my hands on the Akka Pi java tutorials I am trying to creaate a maven project as stated in the tutorial but any time I enter the command to create a maven project I get an error. Be...
Incarnate asked 26/9, 2012 at 2:8

11

Hi I was new to apache spark and i was trying to learn it While creating a new standalone cluster I met with this error. I started my master and it is active in port 7077, i can see that in the u...
Leal asked 22/7, 2014 at 7:57

5

Solved

In Akka, is there a way to restrict messages to actors to be of a specific static type other than using the "Typed Actor" APIs that use an RPC style programming model? Can I use the message passin...
Taft asked 5/4, 2011 at 6:15

4

I've already read the question and answers to What design decisions would favour Scala's Actors instead of JMS?. Usually, we use messaging solutions which have existed for years already: either a ...
Breannabreanne asked 17/4, 2011 at 11:51

2

Solved

I'm attempting to test out Akka with Play 2.5 and I'm running into a compile error I can't seem to get around. I'm following this page from the Play docs: https://playframework.com/documentation/2...
Secunderabad asked 7/3, 2016 at 21:53

17

I'm having some issues today with running a simple TestKit test in Intellij. The tests are for Scala code (I have the Scala plug-in for Intellij) and are based on Ray Roestenburg's example. The In...
Miscarriage asked 16/9, 2013 at 21:58

2

Solved

This is a beginner question. So my app structure looks like src/main/java/... src/main/resources/application.conf src/test/java/... src/test/resources/module/test.module.conf application.conf ...
Earful asked 29/4, 2015 at 4:56

5

When receiving events, Akka Actors will process one message at a time, blocking until a request has been completed before moving onto the next message. This works well for synchronous/blocking tas...
Loraine asked 13/4, 2016 at 7:58

3

Solved

I am working with a data publisher from a java library that I do not control. The publisher library uses a typical callback setup; somewhere in the library code (the library is java but I will desc...
Hesson asked 3/4, 2015 at 16:47

2

I'm currently trying to dynamically create Akka Stream graph definitions at runtime. The idea being that users will be able to define flows interactively and attach them to existing/running Broadca...
Interoceptor asked 26/4, 2017 at 16:30

5

Solved

I'm trying to get Akka going in my Java project, and I'm hung up on a small issue with the Seq type(s) from Scala. I'm able to convert my Java List of ActorRef into a scala.collection.Seq, but the ...
Wrapping asked 22/7, 2011 at 0:56

1

I am trying to compile an Actor with DynamicMessage with Scala Reflection Toolbox The actor code looks like import scala.reflect.runtime.universe import scala.tools.reflect.ToolBox val toolbox = un...
Enright asked 1/3, 2022 at 0:3

4

Solved

Let's imagine an hypothetical HFT system in Java, requiring (very) low-latency, with lots of short-lived small objects somewhat due to immutability (Scala?), thousands of connections per second, an...
Viborg asked 30/3, 2012 at 23:15

3

Solved

We are building a high-throughput low-latency stream processing application. We are using Apache Kafka both as a messaging platform and as a database. It seems like the Kafka Streams and Alpakka K...
Cosmism asked 11/12, 2018 at 15:57

1

I am running a batch job in AWS which consumes messages from a SQS queue and writes them to a Kafka topic using akka. I've created a Sqs Async Client with the following parameters: private static S...
Gropius asked 14/7, 2021 at 11:30

4

Solved

I need to log akka http client requests as well as their responses. While there seems to be a hint of API for logging these requests, there is no clear documentation on how it should be done. My ap...
Endways asked 9/9, 2015 at 9:10

3

Solved

Please note: I am a Java developer with no working knowledge of Scala (sadly). I would ask that any code examples provided in the answer would be using Akka's Java API. I am trying to use the Akka...
Fabricate asked 16/6, 2015 at 1:34

2

Solved

I'm trying to create a basic akka cluster on a Win 7 machine from this documentation: http://doc.akka.io/docs/akka/snapshot/scala/cluster-usage.html and I'm getting an error when I run the seed n...
Stephanistephania asked 31/7, 2013 at 15:33

7

Solved

I am learning akka-remoting and this is how my project looks The project structure looks like project/pom.xml project/mymodule/pom.xml project/mymodule/src/main/resources/application.conf projec...
Giffie asked 23/6, 2015 at 18:59

2

How to use akka in Scala 3 ? I can't find akka dependencies while using scala 3 sbt errors : [error] not found: /Users/admin/.ivy2/localcom.typesafe.akka/akka-actor-typed_3/2.6.15/ivys/ivy.xml [err...
Frontiersman asked 28/7, 2021 at 13:19

7

While each microservice generally will have its own data - certain entities are required to be consistent across multiple services. For such data consistency requirement in a highly distributed l...
Crescent asked 13/5, 2017 at 8:13

3

Solved

I'm designing a small tool that will generate CSV test data. I want to use Akka Streams (1.0-RC4) to implement the data flow. There will be a Source that generates random numbers, a transformation ...
Up asked 13/7, 2015 at 8:46

3

Solved

I have googled a little to find a good explanation of the difference between the above two remoting strategies, i.e. transparent remoting and location transparency. As far as I know, the former is...
Garvy asked 5/5, 2016 at 5:46

5

Solved

The actor based paradigm is pretty cool. Its ability to scale effectively makes it a paradigm to must-evaluate for any concurrent system. I have done some reading about it, and have a decent idea a...
Radiotherapy asked 26/11, 2012 at 2:13

2

Solved

Title is self-explanatory, I want to be able to send a message to a parent actor (meaning I want parent's ActorRef). In Akka Classic (untyped), the ActorRef for a parent actor can be obtained from ...
Dextroamphetamine asked 7/12, 2020 at 1:40

© 2022 - 2024 — McMap. All rights reserved.