Questions tagged [akka]
Akka is an open-source toolkit and runtime simplifying the construction of concurrent and distributed applications on the JVM. It implements the actor model known from Erlang.
8,023
questions
0
votes
0
answers
5
views
Does the Akka's Logging is fine? i am asking for your opinions to shed some light on it
From your experience,
What would you think about Akka's Logging system?
Would you recommend it?
Any special properties?
Does it have defects?
Thanks a lot!
0
votes
0
answers
8
views
Is it possible to change the number of Akka's threads dynamically?
Hello everyone!
A.
Usually, it's possible to do but does it works fine as well with Akka Framework?
I mean if is it possible to change the number of Akka's threads dynamically?
B.
Another good ...
0
votes
1
answer
25
views
Why my Akka main actor stops even though behavior doesn't change?
I have written a small application, but there is a problem that my app doesn't wait for my actors to stop, and stops them before their actions are completed.
I tried to make minimal ActorSystem ...
0
votes
0
answers
13
views
Question : Akka Framework - Can I choose which actor will take the next message? [closed]
Well, there is something unclear for me with Akka Framework.
There is a way for me as a developer to choose which Actor will perform a message?
Let's assume I got 3 actors: A1 , A2, A3.
And I want ...
0
votes
1
answer
26
views
Is it possible to prioritize (give a priority) to specific Akka's Actor?
I've made my research about Akka Framework,
And I would like to know ;
Is it possible to give a priority to a specific actor?
I mean - actors are working while getting a "let" message from ...
0
votes
0
answers
9
views
When should Akka BackoffSupervisor OnStop be used instead of OnFailure?
We have been using Akka BackoffSupervisor for a few cluster singleton actors that are critical for the system and should always be present. These actors are persistent so in case DB failure they need ...
0
votes
1
answer
26
views
Akka.net restart actor system termination on node quarentined
We are developing a cluster with Akka.net v1.4.38 on we have seed nodes that communicate with a external system using Akka.IO.TCP, and multiple client nodes that receive and send messages to seed ...
0
votes
1
answer
18
views
How to create an actor in Akka cluster dynamically
How can i create an actor in akka cluster Sharding dynamically with Cluster Client which will pass message from out side the cluster with akka remoting.
0
votes
1
answer
26
views
Errors with Akka-Typed Java
The Akka documentation makes a distinction between validation error and failure. But, while there is a complete chapter on failure, I did not see much on validation error.
A validation error means ...
0
votes
0
answers
8
views
How to get The TCP Bound handler in akka http
I am migrating from spray to akka-http. While in spray I had
def httpBoundHandler: PartialFunction[Any, Unit] = {
case m: spray.can.Http.Bound => httpListenerRef = Some(sender)
}
What is spray....
0
votes
1
answer
11
views
How to terminate the akka grpc client after calling?
I have an akka grpc client, the code attempts to send a seq to remote python grpc server to get results:
package com.example.predict
import akka.actor.typed.ActorSystem
import akka.actor.typed....
0
votes
1
answer
20
views
Any blogs,articals or docs to learn AKKA Remote internals? [closed]
Any blogs,articals or docs to learn AKKA Remote internals,indepth working how actor created how all connected how messages shared?
Endpoint Reader,Writer,Endpoint Manager
Association handler,
...
0
votes
2
answers
41
views
Should I wrap blocking code with Future within an actor?
I have a question regarding of blocking call handling within an actor. I have a blocking method call blokingProcess() I want to call it within an actor. Should I have to
Wrap this blokingProcess() ...
0
votes
0
answers
20
views
overriding an Actor's "receive" method fails in scala 3
import akka.event.Logging.DefaultLogger
abstract class AbstractLogger extends DefaultLogger {
override def receive: PartialFunction[Any, Unit] = {
case msg => super.receive(msg)
}
}
final ...
0
votes
1
answer
31
views
How to use Cluster singlton or Cluster sharding in Akka-Cluster for million individual Actors?
I have a use case where a million individual actors will be created across the cluster.
The tasks will be received from outside cluster and i have to identify and send the task to assigned single ...
1
vote
0
answers
11
views
Error downloading apex:apex-jorje-ide:1.0-sfdc-187-SNAPSHOT-55042bfc2e
I am using Scala 2.13.9 and SBT version 1.1.1 and I see this error when i run the sbt run command. I do not find this dependency anywhere. I have looked on MVN repositories as well but t could not ...
0
votes
1
answer
35
views
How to handle million individual actors with AKKA Cluster setup?
I have a use case which is million clients data processed by individual actor.And all the actors created on across multiple nodes and formed as a cluster.
When i receive a message i have to send it to ...
1
vote
1
answer
30
views
com.typesafe.config.ConfigException$Missing: reference.conf: No configuration setting found for key 'default'
I created a jar file of my Akka application. When I run the jar file by the command
java -jar file.jar
then I see this error. What could be possibly wrong and how can I fix this?
[ERROR] [04/28/2022 ...
0
votes
0
answers
62
views
flink cluster with zookeeper HA always shutdown: [RECEIVED SIGNAL 15: SIGTERM]
Environment:
flink1.14.4
standalone application mode in kubernetes
according to official steps:
flink cluster: https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/deployment/resource-...
0
votes
0
answers
18
views
I want to implement a distributed workflow system like Dophin scheduler with actor model, is there any mature actor model support java? only akka?
someone say Akka is not the best choice for handling workflows. it is right?
is there any other mature distributed actor model support java?
is the vertx more suitable for this scenario? How is the ...
2
votes
1
answer
65
views
java.lang.NoSuchMethodError: 'void akka.actor.ExtensionId.$init$(akka.actor.ExtensionId)'
I am simply trying to implement a little sample REST endpoint in a scala project using akka.
The code looks as follows
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.{ContentTypes, ...
0
votes
1
answer
39
views
Handleing AskTimeoutException on Akka based application
I have the following HTTP-based application that routes every request to an Akka Actor which uses a long chain of Akka Actors to process the request.
path("process-request") {
post {...
0
votes
1
answer
36
views
Akka Typed - How to sent Terminated message to BehaviorTestKit
I'm trying to unit test my actor's handling of a "Terminated" message for a child actor. The code under test is something like this:
case Terminated(terminatedActor) =>
val ...
0
votes
1
answer
33
views
Testing Akka Typed actors - How can I get an ActorContext?
I'm trying to unit test a helper function of my actor. This helper function spawns some actors and I want to assert that this happens. In order to spawn them, the helper function needs the parent ...
1
vote
0
answers
42
views
Is it possible to use both Kamon Client and Prometheus Client to same port?
build.sbt:
val kamonVersion = "2.5.1"
lazy val kamon = Seq(
"io.kamon" %% "kamon-bundle" % kamonVersion,
"io.kamon" %% "kamon-prometheus" %...
0
votes
0
answers
25
views
How to create child actors in Akka.NET with Dependency Injecton
I want to use akka for concurrent message processing. I am working with objects called Fixture. My design is to have a supervisor actor that gets all the messages and then routes them to another actor ...
0
votes
2
answers
27
views
Error while calling an API using akka in scala
TO start with I am very new to Scala and also I don't have any Java experience also. I am trying to call an API using simple Scala code and running into the errors. Code looks like:
import akka.actor....
0
votes
1
answer
30
views
Dynamic Akka streams sink
I want to build a graph in Akka streams where the source is a Kafka topic (topic_a) and the sink is topic_b (always) and, depending on the message's data, also topic_c (the output message will be ...
2
votes
0
answers
13
views
How to include a cookie in the initial WebSocket client request using akka Client-Side WebSocket Support?
I'm using the akka Client-Side WebSocket package to consume, from my Scala application, a WebSocket endpoint that requires a cookie header in the initial client request.
Looking through the akka ...
0
votes
0
answers
13
views
Akka BehaviorTestKit - Check for anonymous actor spawned of specific type, ignoring order
I'm trying to uss the Akka BehaviorTestKit to verify that an anonymous actor of a specific type is spawned.
I tried to use:
testKit.expectEffectType[SpawnedAnonymous[MyActor.Request]]
When I did this,...
0
votes
0
answers
19
views
akka actor enabled two routers, only one work normally while the other is basically the same
I run into a weird problem, which I don't know why, I create one akka cluster with 2 nodes in my local pc, 127.0.0.1:2551 and 127.0.0.1:2552.
Below is my main actor content
public class ...
1
vote
1
answer
23
views
Scala signature Http has wrong version expected: 5.0 found: 5.2 in Http.class
I am using akka.http in my Scala code in Intellij. But when I try to build my project I get the following error:
scalac: error while loading Http, class file 'C:\Users\XXXXXX.m2\repository\com\...
2
votes
1
answer
46
views
How to set Bearer token in akka-htpp client request
I’m receiving a warning from akka http when trying to make a POST request with a bearer token.
Here is the snippet where I am making the request.
val bearerToken: String = "..."
val resp = ...
0
votes
0
answers
43
views
akka-grpc-maven-plugin throwing error of "Unsupported platform: protoc-3.19.1-osx-x86_64.exe"
I have been using MacBook Pro of 1.4GHz Quad-Core Intel Core i5 laptop. Below is my system configuration
Maven home: /usr/local/Cellar/maven/3.8.5/libexec
Java version: 11.0.11, vendor: AdoptOpenJDK, ...
0
votes
0
answers
62
views
Blocking calls on Akka HTTP server
Why is my akka-http server dropping connections?
The following is a simplified version of a problem I am facing.
I have a akka-http server.
On a route, I have to make a blocking call to a remote ...
0
votes
1
answer
27
views
Getting 'unable to resolve overloaded method actorRef' error when building websockets in Play + Scala
I'm trying to follow the instructions on the Play website here to set up a basic websocket. However, when trying to use the following code I'm getting an error:
Cannot resolve overloaded method '...
1
vote
1
answer
28
views
Akka Typed testing - Expect message of type without knowing message details
Let's say I have an Actor (OrderGenerator) that in response to an incoming message (GenerateOrder), sends a message to another Actor (OrderProcessor) of type Order.
case class Order(orderId: String, ...
1
vote
0
answers
42
views
Substream Source(EntitySource) cannot be materialized more than once
I'am trying to implement file upload functionality in my application using Akka HTTP. I am using Akka version 2.5.32 and Scala version 2.11.12. I write a simple code with directive storeUploadedFile, ...
0
votes
0
answers
42
views
Akka on android, "No field value in class Ljava/lang/String;"
I am trying to run Akka (typed) on Android 8. However when I try to create the ActorSystem it fails because the akka.util.Unsafe class try to access a missing "value" field on String:
// '...
2
votes
0
answers
114
views
AKKA.NET Problems when multiple child actors tell a message to their parent
I'm trying to create a gerarchy of actors like this:
public class Actor1 : UntypedActor
{
private int _numberOfChildActive;
protected override void OnReceive(object message)
...
0
votes
1
answer
22
views
can we have a default parameter in java akka http?
like below code
post(() -> route(
pathPrefix("scheduleStatus", () ->
path("send", () ->
...
0
votes
0
answers
35
views
How to reconnect akka-http client websocket
Im working on an application that has a dedicated actor to process incoming data over a websocket connection. What I am finding is that occasionally, the websocket will terminate, close unexpectedly. ...
0
votes
0
answers
21
views
why akka remote actor shutting down immediately after running in akka-remote 2.6.19 only when I'm using 1.6.2
I'm using 2.6.19 version akka-remote dependency and I started to run my actor but it's terminating immediately. This is working fine with sbt =1.2.8
class actorTest extends Actor{
override def ...
0
votes
1
answer
39
views
How to use https in play framework?
when I use https in play framework it shows like this
WARN akka.actor.ActorSystemImpl akka.actor.ActorSystemImpl(play-dev-mode) Illegal request, responding with status '400 Bad Request': Unsupported ...
0
votes
1
answer
30
views
Aggregating multiple child actor responses in Akka Typed
I'm currently porting an Akka Classic app to Akka Typed. I have the following components:
HttpService - Not an Actor
JobDispatcher - An Actor
JobWorker - Child actor of JobDispatcher
The ...
1
vote
0
answers
40
views
Akka Http: How to handle high throughput through a proxy?
I would like to handle 3.000 requests per second via proxy usage.
The following code without proxy works without problems and can handle 3.000 requests per second with an average send-response time of ...
-1
votes
2
answers
77
views
Akka: custom HttpHeader, convert HashMap to Iterable<HttpHeader> in java
I'm trying to generate custom HttpHeader in akka. I've a HashMap of header entries which I need to convert to Iterable.
Here's my code:
import akka.http.javadsl.model.HttpHeader;
HashMap<String, ...
0
votes
1
answer
43
views
Need help understanding return type for Akka Typed ask
I am trying to get "ask" working for Akka Typed. I have followed examples online, and I thought I pretty much replicated what they showed, but I'm getting an compiler error when I try to ...
0
votes
1
answer
28
views
Influxdb Alpakka connector not writing to database
I'm trying to write into the Influxdb (running in a docker container with version 2.0).
I'm using Scala and Reactive Streams. Therefore the Alpakka connector (https://doc.akka.io/docs/alpakka/current/...
0
votes
1
answer
35
views
Unit testing of tls enabled in akka http
I have enabled tls in my application to use HTTPS instead of HTTP. Now I want to write its unit test.
path("Ping") {
complete("Pong")
}
Get("/Ping") ~> ...