Questions tagged [akka-remoting]

Akka is a library for building concurrent scalable applications using the Actor Model. Akka remoting is designed for communication in a peer-to-peer fashion. The remoting capabilities of Akka 2.0 are really powerful.

Akka is a toolkit and runtime for building highly concurrent, distributed, and resilient message-driven applications on the JVM. It helps in building concurrent scalable applications using the Actor Model. Akka remoting is designed for communication in a peer-to-peer fashion. The remoting capabilities of Akka 2.0 are really powerful.
Remote actor is an actor which listens on some given port. The remoting contains functionality not only to lookup a remote actor and send messages to it but also to deploy actors on remote nodes. These two types of interaction are referred to as: Lookup, Creation
It is most commonly used in distributed applications that run across the network.

63 questions
11
votes
1 answer

"max allowed size 128000 bytes, actual size of encoded class scala" error in akka remoting

I want to use Akka Remoting to exchange message over network between actors, but for large String message i got the following error: akka.remote.OversizedPayloadException: Discarding oversized payload sent to Actor :: max allowed size 128000…
Saeed Zarinfam
  • 9,818
  • 7
  • 59
  • 72
5
votes
1 answer

Getting Akka.NET to connect to a remote addresses

All the demos I have found showing how to get started with remoting in Akka.NET demonstrate the simplest use case where the two actors are running on the same machine using localhost. I am trying to get an Akka.NET actor to connect to a remote…
Maxim Gershkovich
  • 45,951
  • 44
  • 147
  • 243
4
votes
0 answers

How do i keep Akka Java actors alive on remote systems ready receive message-deployment?

I am trying to create AKKA actor clusters on distributed systems with JAVA. I am able to use them in single machine. Just wondering suppose I am keeping the actors in different machines, how do i keep them alive to be ready to receive…
4
votes
2 answers

Ways to maintain back pressure in Akka Streams involving multiple JVMs

I'm aware that as of Akka 2.4.16, there is no "remote" implementation of Reactive Streams. The specification focuses on a stream running on a single JVM. However, considering the use case to involve another JVM for some processing while maintaining…
2
votes
1 answer

Akka.Net Streams and remoting (Sink.ActorRefWithAck)

I've made quite a simple implementation with Akka.net Streams using Sink.ActorRefWithAck: a subscriber asks for a large string to a publisher which sends it by slices. It works perfectly fine locally (UT) but not remotely. And I cannot understand…
Xavier
  • 66
  • 1
  • 6
2
votes
0 answers

Akka Remoting: Multiple Deployment Config using Props.withDeploy(... ).

I am creating a sample with Akka Remote Actor with RemoteLookupProxyForwarder as define in Akka In Action book. My requirements are like create an actor remotely but using code configuration. RemoteLookupProxyForwarder is work like to lookup remote…
Harmeet Singh Taara
  • 6,483
  • 20
  • 73
  • 126
2
votes
2 answers

How to handle a stale akka.net remote iactorref

I am using remote actors in a akka.net in a windows service that stays up long term. I obtain an IActorRef for the remote actor using ActorSelection and I keep this IActorRef alive for an extended period of time in the service. The IActorRef points…
cfcal
  • 161
  • 6
2
votes
1 answer

How can I send messages to a remote actor via CLI with Akka remoting?

I have a remote actor, Bar and a local actor, Foo. I want to use Foo to pass messages to Bar on each invocation of a CLI. Bar can be passed messages successfully, but Foo hangs while waiting for a message. To fix this, I added a sys.exit(0) at the…
erip
  • 16,374
  • 11
  • 66
  • 121
2
votes
1 answer

AKKA (V2.3.9) Spring Integration:: Cluster Remote Routees failover due to Spring Class Serialization error

I am setting akka cluster (using akka library version 2.3.9 ) with one master actor and multiple worker actor. Master Actor is configured with pool cluster aware router. Deploying application with forming 4 cluster nodes. Initially all the nodes are…
2
votes
0 answers

Disassociated exception in Akka.Remoting

Using Akka.net I am trying to implement simple scenario. I have created 2 servers and 1 client, where Servers receives the messages sent from client and processes it. Setup works fine sometimes and sometimes it gives following error, I am not able…
Pankaj Chouthmal
  • 195
  • 1
  • 11
1
vote
0 answers

No response from remote for outbound association. Associate timed out after [15000 ms]

Does anyone know why do we get association errors? I have a server and client system where actors from the client-side send messages to the server actor through Akka remoting and both server and client are on the same local machine but using…
Najarp
  • 21
  • 1
  • 2
1
vote
1 answer

Akka.NET: Dead Letters to Remote Actor

I am learning how to call a remote actor from a different machine. To simulate two different machines I have a Host machine and the other one is a Virtual Machine (VM). The Network Adapter is set to NAT because with this setting I am able to ping…
Stuxen
  • 708
  • 7
  • 21
1
vote
1 answer

Why do multiple constructors in messages cause Akka.NET to fail delivery?

I've got a very simple implementation using Akka.NET remoting. Specifically I have two actors: public class ClientQueryActor : ReceiveActor { public ClientQueryActor(ActorSelection stockBarcodeActor) { this._stockBarcodeActor =…
Maxim Gershkovich
  • 45,951
  • 44
  • 147
  • 243
1
vote
0 answers

Akka remoting won't start

I’m new to Akka and I’m working through Jason Goodwin’s well written book Learning Akka. His examples use activator though, and since activator is gone I’ve recreated his examples from chapter 2 without activator. The problem is that my code…
Dean Schulze
  • 9,633
  • 24
  • 100
  • 165
1
vote
1 answer

AKKA clustering: send and recieve actor messages between 2 remote nodes

I have 2 project (sbt), say projectA and projectB. projectA dependsOn projectB. How do i configure akka cluster such that both the projects passes messages using actors? Both projectA and projectB forms a cluster with seed -nodes.
nocturnal
  • 395
  • 2
  • 6
  • 15
1
2 3 4 5