[akka-user] Re: Memory Bounding Akka Streams

THANK YOU for your responses; and very helpful Endre to explain! Need to Google up those JS interfaces for async and sync! So, then, if you've got a system of remote services talking to each other; you pretty much need to be coding to interfaces which support the Reactive protocol on (both) sid

[akka-user] Re: What's the replacement for Akka Actor Publisher and Subscriber?

Right; can you provide a Blog URL or something to explain further? What is the recommended architecture when you want to stream data between remote Actor-based services? i.e. the implementations of Actor Publisher/Subscriber which actually work across remote boundaries (location transparency

[akka-user] Re: Best practices on message design

Look at Kamon for tracing: http://kamon.io/core/tracing/core-concepts/ On Saturday, October 8, 2016 at 2:16:56 AM UTC-4, Shivakumar Ramagopal wrote: > > Hi, > > I'm looking for a guide for designing messages in an Akka system. My main > goal is to be able to trace messages as they pass from on

[akka-user] Closing an outgoing TCP connection (akka.stream.scaladsl.Tcp().outgoingConnection) without terminating the ActorSystem

I have a TCP client by connecting the Tcp().outgoingConnection to a Flow.fromSinkAndSourceMat where the sink and source are Sink.actorRef and Source.actorRef. In general this works well. But I can't find a way to close the TCP connection from the client side. I can complete the stream by sendin

Re: [akka-user] How to handle web socket message to upload base64 encoded string of 10mb file

thanks for quick reply rafal . Yes you hav mentioned right , I am getting the 'message does no arrive' , but not any exception . I have tried with the TextMessage.Streamed , but no progress from here also . Please find the code below : - case TextMessage.Streamed(stream) => { stream .l

Re: [akka-user] How to handle web socket message to upload base64 encoded string of 10mb file

Please elaborate on "unable to handle it" -- are you getting an exception, message does no arrive, something other? Also it would be helpful if you showed your code for TextMessage.Streamed case because that's how large messages would show up. I don't know the specifics but there appears to be a

[akka-user] Re: ('=') sign still not allowed in query string even with Uri.ParsingMode.Relaxed? (akka/akka#18479)

Hi Richard, "GROUP=10380?page=2" isn't a well formed query and therefore can't be parsed even in relaxed mode. akka/akka#18479 provides a way to prevent parsing of the query component and to just look at the raw query string. You can access your query

[akka-user] Re: akka.http.scaladsl.model.Uri's apply() methods should still take charset and mode parameters?

Hi Richard! See [1] for the discussion related to your question. [1] https://github.com/akka/akka/pull/18715#discussion-diff-41831981 Cheers André On Sunday, October 9, 2016 at 6:49:23 PM UTC+2, Richard Imaoka wrote: > > Hi, > > While I was trying to work on akka/akka-http#276 >