Re: [akka-user] [akka-stream] how to control the throughput of a certain flow

The Pipelining and Parallelism chapter in the documentation is a good read. Regards, Patrik On Wed, Nov 11, 2015 at 4:13 AM, Leon Ma wrote: > Hi, > > Assuming I have below flows:

Re: [akka-user] Akka cluster sharding exception propagation to the parent actor

Are those exceptions because you send new messages to the entity actor? Do they stop when you stop sending messages to the actor? BackoffSupervisor only helps for persist failures (database exception) or failures during recovery, i.e. when the actor is stopped. If you throw exception in

[akka-user] Re: FTP library

Just in case somebody is interested: I decided to go with akka-camel. Works fine for my simple use case. Nevertheless I would be curious about what a better solution would be for more challenging use cases (very large files, many concurrent uploads). On Monday, November 16, 2015 at 4:04:27 PM

Re: [akka-user] Re: Is it possible to use a the stream materialized value to dictate the HTTP response status code?

Hi Tim, Great that you figured it out, I tried to understand your question between a train and a plane and couldn't get to the bottom of it. Glad that you like our approach :-) Regards, Roland Sent from my iPhone > On 16 Nov 2015, at 06:15, Tim Harper wrote: > > I

Re: [akka-user] Re: Cluster Sharding - watching for termination of sharded actors.

That sounds serious. Please create an issue , and we can continue the investigation there. Thanks for reporting. /Patrik On Thu, Nov 12, 2015 at 3:31 PM, Marcin Sośnicki wrote: > Hi, > > I have done some deeper digging into that and it

Re: [akka-user] Testing Streams - What's a Subscription?

Hi Greg, Try with .runWith(TestSink.probe[String]) .request(2) .expectNext You should not expect any elements until you have requested for elements. /Patrik ​ On Sat, Oct 24, 2015 at 8:26 PM, tigerfoot wrote: > Hello, > > I'm trying to run a test of a stream from RabbitMQ

[akka-user] FTP library

Hi all, I will have to do some FTP uploads from within an akka-based application. My current idea is just to go with apache-commons FTPClient and put the actor on a separate dispatcher to avoid issues with the inevitable blocking calls. This will definitely work and also not cause any issues,

Re: [akka-user] Supervision: Who just died

On Wed, Nov 11, 2015 at 8:29 PM, Arne Claassen wrote: The one thing I keep struggling with is the opaqueness of failures in Akka, > i.e. that all the conditions at failure time are not available to either > the actor or the supervisor. > > What I just came across was a failure

Re: [akka-user] Akka-Remoting Field Serialization

Thanks Patrik, Will give that a shot -- >> 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 --- You received this

Re: [akka-user] What type of dispatcher to use when launching large number of Actors

What problems have you noticed with the default dispatcher or a separate dispatcher based on the fork-join dispatcher? /Patrik On Tue, Nov 10, 2015 at 11:55 PM, wrote: > Maybe better use a distributed solution through a clustered aware router > with pool of actor.

Re: [akka-user] Cluster Sharding Proxy vs Cluster Client

Cluster Client is for communication between two different clusters. You can put the frontend nodes in one cluster and backend nodes in one cluster and use Cluster Client from frontend to backend. However, it's easier and the tooling is richer if you use one cluster with different backend/frontend

Re: [akka-user] Re: FTP library

It would be awesome to have one based on Akka Stream TCP. Are there any FTP compliance test suites to use? -- Cheers, √ On 16 Nov 2015 18:04, "rklaehn" wrote: > Just in case somebody is interested: I decided to go with akka-camel. > Works fine for my simple use case.

Re: [akka-user] ActorSelection vs ActorRef

But that is not really accurate, isn't it? When restarted the ActorRef is still perfectly valid and you only need to watch actors in case you have reason to believe that they will be terminated. Also, messages don't get lost during the restart, because the mailbox isn't restarted (well

[akka-user] Akka-streams TLS-PSK support

Hello everyone, I am exploring using akka-streams as a TCP client. Unfortunately my use case requires the usage of pre-shared keys as the cipher suite (specifically TLS_PSK_WITH_AES_128_CBC_SHA) instead of using certificates. Looking through the source code and test cases

[akka-user] Re: Akka-streams TLS-PSK support

Have you tried adding the BouncyCastleProvider as a security provider? Then making your normal JSSE calls? Security.addProvider(new org.bouncycastle.jce.provider.BouncyCastleProvider()) -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Re: Akka Stream and Http 2.0-M1 Released!

With these latest foundational changes, is akka-http 2.0 intended to be the 'spray parity' release? If not, is there a roadmap for an akka-http client as rich as Spray's and akka-http server as performant as Spray's? -- >> Read the docs: http://akka.io/docs/ >> Check

Re: [akka-user] Akka-streams TLS-PSK support

Hi Chris, Jim responded quicker than I managed to; thanks! :-) I'll add a bit more positive hints to the above suggestion, it seems that BouncyCastle does implement the cipher you're after:

Re: [akka-user] Supervision: Who just died

On Mon, Nov 16, 2015 at 5:57 PM, Arne Claassen wrote: > Ah. Supervision is just a special receive loop behind the supervisor > strategy, right? Did not think of checking sender(). > yes, it is > > thanks, > arne > > On Monday, November 16, 2015 at 6:12:45 AM UTC-8, Patrik

[akka-user] Re: microservices multi actor persistence and sharding question.

Hello, I found a solution but it won't work for microservice kind of setup. But it might useful, for others who are trying to use Akka sharding in monolothic applications. Please let me know if you guys find any other alternatives. Essentially, the only way sharding between multiple services

Re: [akka-user] ActorSelection vs ActorRef

You are right, Adam. I missed that the question was about restarts. /Patrik mån 16 nov. 2015 kl. 18:50 skrev Adam : > But that is not really accurate, isn't it? > > When restarted the ActorRef is still perfectly valid and you only need to > watch actors in case you have

Re: [akka-user] Akka-streams TLS-PSK support

Thanks for the quick replies! Unfortunately I think I'm running into this issue of Bouncycastle being a JCE provider but not a JCCE provider. E.g.: val cipherSuites =

[akka-user] Akka/Kafka

Apologies if this is a naïve question. Kafka seems like great technology and a great companion to Akka. It has a dependency on Zookeeper, and my understanding is that's just for the watermarks. I'm not sure if this dependency on ZK is a bad thing, but I've certainly seen criticism of ZK and

[akka-user] Play application with http / streams at 2.0-M1 fails to "run".

Hi Everyone, I thought I would start learning about Akka http / streaming and so have added them to my depoendencies in build.sbt. But am now getting an error whenever I try to RUN my Play application. I am not sure what I can provide to help with this one; Hopefully it is just something

Re: [akka-user] Re: I get strange error with 2.0-M1

It can very well be. If the response is longer then 2 sec, this bug might trigger. On Sun, Nov 15, 2015 at 4:28 PM, Konrad Malawski < konrad.malaw...@typesafe.com> wrote: > Hi all, > thanks for trying out the early Milestone and reporting the problem! > We believe there is a bug in how the idle

[akka-user] Re: 1.3.5 The finer points of stream materialization

Tim, Sorry, I read *Akka Stream and HTTP Experimental Scala Documentation* in bits and pieces and often misinterpret it. Materializers provide a key/value mapping and Attributes and ActorAttributes provide specific customizations of streams so this makes me wonder if streams are intended to

[akka-user] Re: Akka cluster failover- race condition

Hi, What you describe is what is called split brain, where one cluster becomes two clusters that does not know of each other because of communication failure, it can happen when you use the built in auto downing in akka-cluster. Basically there are two ways around it. One is to not use auto

[akka-user] Re: [akka-http] akka-http-session project: client-side sessions, remember me, csrf

Hello, Without steering you off your current path, I just wish to mention JWT > (Json Web Token) which is a token forma t typically sent > as a OAuth2 Bearer Token (using the HTTP Authorization header). JWT has > security considerations as well as a client side singed session

Re: [akka-user] Akka remoting and Docker

> On 15 Nov 2015, at 16:01, Alex Wouda wrote: > > Thanks. > > Also I needed the bind-port and port to be the same. That’s because of the way you forward the ports: 9100:9100. The second one is the container port. If you set that to 2552, you can use bind-port = 2552. Heiko

[akka-user] Unique key per poor remote worker actor

I have implemented CQRS pattern for storing my user, bank, and wallet. All these of them have similar commands such as create, lock, unlock, and close commands. Therefore, I created a a base class that helps me reduce the amount of redundant code I have to write (and these commands are very