8,238 questions
- Bountied 0
- Unanswered
- Frequent
- Score
- Trending
- Week
- Month
- Unanswered (my tags)
1
vote
0
answers
86
views
Why is mapAsync internal buffer not getting garbage collected?
I've written following snipped to mimic my problem:
implicit val actorSystem: ActorSystem = ActorSystem()
implicit val executionContext: ExecutionContext = actorSystem.dispatcher
...
1
vote
0
answers
82
views
Piping an Akka Flow via Java Streams
I have an Akka Flow<ByteString, ByteString, NotUsed>. My goal is to feed the ByteStrings to an external library and send its result downstream. The external library, however, consumes and ...
0
votes
1
answer
102
views
Scala Akka actors - Message to Actor was not delivered
I have an application built using Akka actor framework which reads messages from a kafka topic and processes them. My code is structured in the following way:
I have a KafkaConsumerActor that reads ...
1
vote
1
answer
90
views
Using Saxon-EE, is it possible to stream the input source for a transformation
We are streaming the content of a (rather large) XML file. Before we process the content downstream, we want to transform it using Saxon.
Using the following Akka flow:
public Flow<ByteString, ...
0
votes
1
answer
86
views
Query regarding event persistence and projection completion status check
Is there a way I can check the status of projection for a Pekko/Spring Boot app somehow, as I want to trigger next event only after one projection gives status OK.
private ...
0
votes
0
answers
44
views
How to make Akka.net crash the application?
The application is running in a Docker container with limited RAM.
There's some kind of memory leak in the application (the problem is being investigated), which accumulates over a long time. When an ...
0
votes
0
answers
59
views
Issue getting akka or pekko TestKit EventFilter to work as expected
I have a simple 'classic' actor that just recieves a message and logs string Bingo to INFO. In my test I setup an InfoFilter EventFilter to verify the log.info message call. Debugging I can see that ...
0
votes
1
answer
48
views
Proper handling of akka events on rollback
For simplicity, we have ff info:
Command1(name: String)
State1
Event1(name: String)
State2(data1: String, name: String)
I wanted to display the person's gender in State2 and for that to work I need ...
0
votes
2
answers
76
views
Pass a wildcard class as part of actor message with Akka actors?
I am trying to simplify the handling of messages to actors in my application. It has become quite large and messy, so I'm refactoring how I pass around actor references.
The plan is to:
Have a master ...
0
votes
0
answers
37
views
Is there a mechanism to access a NodeJS app remotely
I have a third party TypeScript library that I would like to access from my Scala application. The library I want to use is dydx-v4-clients
I have been able to access the library by creating a facade. ...
0
votes
0
answers
81
views
Why is my websocket failing to connect? NextJS -> NGINX -> Scala(akka-http)
Background:
I have a Scala (with akka-http) webserver running behind NGINX. I also have a NextJS application running behind the same NGINX.
My goal here is for the NextJS application to establish a (...
0
votes
1
answer
69
views
Integration tests for akka http endpoints
I have an akka based application, and it has Application.java file which has structure like what we have defined here.
Now I want to write integration tests for akka http endpoints in this application,...
0
votes
1
answer
63
views
Why is my actor ask getting dead letters?
Background:
I have the following flow process:
Peer Actor on one instance generated and sends a PeerRequest proto (via http) to another instance
The PeerServer receives and process the request
It ...
0
votes
1
answer
85
views
How to add "default" Receive behaviour to an AKKA Actor that is able to change its behaviour?
Background:
I have an Actor called Peer. Within my application, a Peer represents a connection between the server that created it and another server. It is essentially a http-client.
When the instance ...
2
votes
1
answer
62
views
Is encrypting a public key enough security to replace SSL? [closed]
I'm looking into implementing OTR (off-the-record) protocol into my de-centralised messaging app (written in Scala with akka and akka-http). I was originally attempting to use SSL, but it seems ...