[akka-user] Message passing between ShardEntityActors and RemoteActors

Hi everyone, I have a scenario where I use Cluster Sharding as follows. Each Node/Machine: 1. Cluster Sharding enabled ActorSystem1 running on port behind Docker Container 2. There is only one ShardType in this ActorSystem1 and 10 Shards 3. The Entity actors are persistent usi

Re: [akka-user] Akka Streams - Retry failed RPC call.

I am skeptical of this working. The reason being is the following example. I would expect my printed output to be "1" "2" "4". But instead I get "1" "2" "Exception in thread "main" java.lang.RuntimeException: failed in source". So it seems that I am missing something here. object Test extends

[akka-user] illegal-rawheaders

Hi everyone. I've been using akka with spray and, later, akka-http. Right now I'm confused with configuration and *illegalHeaderWarnings* in particular. First, I added this to my *application.conf*: akka.http { host-connection-pool { parsing.illegal-header-warnings = off parsing.error-log

[akka-user] akka.remote.transport.ProtocolStateActor/invoke is reporting as SLOW on NewRelic

On our NewRelic dashboard this is the output: >From the point of view this invocation is extremely slow. I am not sure if thi

Re: [akka-user] Akka Streams - Retry failed RPC call.

def downloadS3ObjectFlow(s3Client: S3Client, bucket: String): Flow[String, ByteString, NotUsed] = { Flow[String].flatMapConcat { key => log.debug(s"Downloading $key") val data: Source[ByteString, NotUsed] = s3Client.download(bucket, key) data.recoverWithRetries(3, { ca

[akka-user] Akka Streams - Retry failed RPC call.

Hey all, Currently I have the following flow to take in an S3 key and download that that file from S3. def downloadS3ObjectFlow(s3Client: S3Client, bucket: String): Flow[String, ByteString, NotUsed] = { Flow[String].map { key => log.debug(s"Downloading $key") val data: Source[By

[akka-user] Re: XMPP chat server vs Akka TCP

Hi, XMPP is an application-level protocol while TCP is a transport-level protocol. In fact, XMPP usually runs *on top of* TCP. So, yes, you can use Akka TCP to implement XMPP. Comparing XMPP to what you probably have right now is that in your current application you used your own custom protoc

[akka-user] multiple request-response cycles using single materialized stream

I have a service that can easily be expressed as a Flow from Request to Response ("the service flow"), which I want to accept up to (e.g.) 10 requests at given point in time, rejecting the overflow. I want to model both service and clients as streams. In order to impose a single buffer boundary

[akka-user] XMPP chat server vs Akka TCP

Hi, I have to develop a chat web application + android/ios clients. I did a sample using Akka Actors, using Akka TCP. So I have an TCPUserActor that receives the connection, and after that I have some UserActor for each user in the application. But I friend told me that chat applications uses

Re: [akka-user] Dependency issue

You're welcome On Thu, Feb 23, 2017 at 1:59 PM, Steve Winfield < mail.stevewinfi...@gmail.com> wrote: > All right, it seems to work now, thank you very much! > > Cheers, > > -- > >> Read the docs: http://akka.io/docs/ > >> Check the FAQ: http://doc.akka.io/docs/akka/ > current/add

Re: [akka-user] Dependency issue

All right, it seems to work now, thank you very much! Cheers, -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https://groups.google.com/group/akka-user

Re: [akka-user] Akka persistence cluster sharding support for 2 active-active data centers

This is difficult to solve and current Cluster Sharding / Persistence doesn't support it well. Lightbend has got this question from customers several times and we have a design for a solution sketched up. If you are a Lightbend customer I suggest you vote for this feature (create a support case) to

Re: [akka-user] Akka cluster - reactivemongo.api.MongoConnection not serializable

DaemonMsgCreateSerializer is used for remote deployed actors, e.g. Router Pools. You probably have the MongoConnection as a constructor parameter to your actor (a Props parameter). You have to create or lookup the MongoConnection from your actor instead, or not use remote deployed actors. /Patrik

[akka-user] Akka cluster - reactivemongo.api.MongoConnection not serializable

Hi, In a context of akka cluster with several nodes, I got the below exception : [info] akka.remote.MessageSerializer$SerializationException: Failed to serialize remote message [class akka.remote.DaemonMsgCreate] using serializer [class akka.remote.serialization.DaemonMsgCreateSerializer]. [i