|
Alpakka RabbitMQ direct reply-to support
|
|
0
|
498
|
March 9, 2021
|
|
Resolve issue (542) in a akka-management
|
|
0
|
711
|
August 23, 2019
|
|
Akka Stream kafka Configuration to investigate hanging consumers
|
|
0
|
1632
|
September 7, 2019
|
|
Send message on websocket
|
|
0
|
564
|
September 30, 2019
|
|
Akka on kubernetes k8s. Downing unreachable nodes
|
|
0
|
741
|
November 14, 2019
|
|
Message akka.io.Tcp$Register was not delivered
|
|
0
|
794
|
January 4, 2020
|
|
What happens when Akka Stream backpressures when the load is very high?
|
|
0
|
562
|
February 18, 2020
|
|
Replace the response with some value
|
|
0
|
510
|
May 25, 2020
|
|
pathPrefix with PathMatcher greater than 2
|
|
0
|
495
|
May 26, 2020
|
|
Akka projection on events that are not tagged
|
|
0
|
430
|
September 15, 2020
|
|
Event source : trigger snapshot on command
|
|
1
|
419
|
July 24, 2024
|
|
How to generate ActorRef[StatusReply] using the Asynchronous testing API
|
|
0
|
654
|
October 7, 2020
|
|
Testing cluster using Akka's test kit: ActorSystem name mismatch - how should one configure the set-up
|
|
0
|
1169
|
October 7, 2020
|
|
Cluster sharding automatic passivation
|
|
0
|
464
|
October 22, 2020
|
|
[error] akka.actor.OneForOneStrategy [sourceThread=application-akka.actor.default-dispatcher
|
|
0
|
932
|
November 11, 2020
|
|
Akka HTTP Allow illegal encoding
|
|
0
|
1076
|
November 20, 2020
|
|
Configuration for in-memory persistence for integration test of cluster
|
|
0
|
437
|
December 9, 2020
|
|
Akka gRPC IDE Support?
|
|
0
|
687
|
August 3, 2021
|
|
Casting nested Scala collections to Cassandra types using Alpakka Cassandra
|
|
0
|
435
|
March 1, 2022
|
|
Akka cluster node unreachable when update distribute data in different nodes
|
|
0
|
467
|
August 10, 2022
|
|
JNA error when using scaladsl.testkit for Cassandra on a M1 apple silicon
|
|
0
|
588
|
September 1, 2022
|
|
Akka with java 1.8
|
|
1
|
323
|
July 23, 2024
|
|
[outbound connection to [akka://abc@149.71.33.186:25520], message stream] Upstream failed, cause: StreamTcpException: Tcp command [Connect(149.71.33.186:2550,None,List(),Some(5000 milliseconds),true)] failed because of akka.io.TcpOutgoingConnection$$anon
|
|
0
|
433
|
July 10, 2023
|
|
What is this context.system.eventStream.subscribe?
|
|
1
|
33
|
July 19, 2024
|
|
What is a difference between `receivePartial` and `receive`?
|
|
1
|
51
|
July 19, 2024
|
|
Migration from netty to artery
|
|
1
|
55
|
July 15, 2024
|
|
What is the correct way to ensure that Guardian actor restarts?
|
|
1
|
73
|
July 12, 2024
|
|
java.lang.IllegalStateException Sink.asPublisher(fanout = false) only supports one subscriber
|
|
5
|
245
|
July 8, 2024
|
|
How can I send a message to an actor with a delay?
|
|
2
|
240
|
July 4, 2024
|
|
Unable to properly terminate the alpakka Kafka Plain source(autocommit) in GraphDSL Stream
|
|
0
|
44
|
July 7, 2024
|