Re: [akka-user] List of defined rest api's in akka-http based application

Thanks. I had already read about the akka-http support for swagger. But was wondering, if akka-http itself provide any methods to get the defined api's. On Monday, July 4, 2016 at 8:33:53 AM UTC+5:30, Siva Kommuri wrote: > > Hmm, by introspection - not sure. > > You may want to look at swagge

[akka-user] gRPC and Akka

Hello, Does anybody have any experience to share of interfacing gRPC with Akka? I want to do an implementation for myself but would like to learn what other people have experienced doing this including successes and any pitfalls. -- >> Read the docs: http://akka.io/docs/ >

[akka-user] Question about akka-http ssl loose config

Hi: I'm using singleRequest with custom HttpsContext Does the withAcceptAnyCertificate param of sslConfig.loose work for AKKA-http client?? Thanks and regards, wuzhonglin -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/d

[akka-user] Patterns.Ask replacement

Hi, Is there any possibility to replace akka.patterns.ask / pipe communication with akks-streams? I was looking for at least small example, but could not find it. I suppose that it can be done with BidiFlow, but I am not sure if I know how. I would be very grateful for such example. Thank you

Re: [akka-user] LEAK: You are creating too many HashedWheelTimer instances

Patrik, I suspected it might be from Cassandra client driver too. I haven't seen those errors for two days. Will add the "ch.qos.logback' like you suggested below. Thank you very much! Yan On Tuesday, July 5, 2016 at 5:11:19 AM UTC-5, Patrik Nordwall wrote: > > Could it be that these are crea

Re: [akka-user] Re: Akka Multi Node Testing

Unfortunately not, I gave it up, as I had other duties. Csaba 2016-06-29 19:51 GMT+02:00 Slawek Mazur : > > Hi > > did you manage to run this code sample? I'm on version 2.11:2.4.7 and I can't figure out how to configure MultiNode config for Java. > > > Best > SM > > > > > W dniu poniedziałek, 22

[akka-user] Akka WebSocket as an Api

I have a chat application developed in Akka and Scala using Play framework WebSockets. I want to make it as an Api based service. For connection , i have used the similar block from official documentaton as: object HandlerClass { def props(out: ActorRef) = { Props(new SocketH

Re: [akka-user] Bad example in documentation

Thanks for reporting, made the ticket: https://github.com/akka/akka/issues/20885 Would be awesome if you could submit a pull request to fix this mistake, thanks in advance! On Tue, Jul 5, 2016 at 12:06 PM, Patrik Nordwall wrote: > Thanks for reporting. Could you please open a pull request with

Re: [akka-user] How to find Oldest node in Akka Cluster Singleton

You have to restart the ActorSystem (or JVM) tis 5 juli 2016 kl. 12:51 skrev Madabhattula Rajesh Kumar < mrajaf...@gmail.com>: > Thank you Patrik for the details. I am using isOlderThan method. It is > working. > > I have an another query :- > >- How to restart the cluster? Do we have a API f

[akka-user] Re: Disassociation happening only in one direction (Akka 2.4.7)

Adding logs for more clarrity 2016-07-04 03:19:14,970 DEBUG akka.remote.EndpointWriter - Disassociated [ akka.tcp://SystemA@192.168.236.12:3001] <- [akka.tcp://SystemB@192.168.236.139:3001] 2016-07-04 03:19:14,970 DEBUG akka.remote.EndpointWriter - Disassociated [ akka.tcp://SystemA@192.168.236.1

Re: [akka-user] How to find Oldest node in Akka Cluster Singleton

Thank you Patrik for the details. I am using isOlderThan method. It is working. I have an another query :- - How to restart the cluster? Do we have a API for that? Regards, Rajesh On Monday, July 4, 2016 at 12:08:38 PM UTC+5:30, Patrik Nordwall wrote: > > Normally you would use the Clust

Re: [akka-user] Akka cluster + sharding + persistence: LeaderChanged twice in very short time

On Fri, Jul 1, 2016 at 6:50 PM, Daniel Lopes wrote: > Apologies, that last comment was a bit ambiguous. > The slow down might be the result of quite a few moving pieces, not > necessarily cluster sharding related - but that's what I'm trying to find > out :) > > Each node reads from kafka (dedica

Re: [akka-user] LEAK: You are creating too many HashedWheelTimer instances

Could it be that these are created by Netty via Cassandra client driver via akka-persistence-cassandra? You can try to add "ch.qos.logback" % "logback-classic" % "1.1.3" dependency and enable logging in logback.xml for That might show you what the Cassandra driver is doing, e.g. scheduling reconn

Re: [akka-user] PersistenceQuery: Materialize view to datastore - When should the query stream be stopped?

since basic (global) tagging is unfeasible in cluster environments, does "sharded tagging" make sense in your opinion? I wonder what overhead I'd have with that technique using cassandra... I'll have to do some tests On Tuesday, 5 July 2016 12:05:29 UTC+2, Patrik Nordwall wrote: > > I think so

Re: [akka-user] Bad example in documentation

Thanks for reporting. Could you please open a pull request with the fix? Regards, Patrik On Sat, Jul 2, 2016 at 12:31 AM, Sergey Sopin wrote: > Hi, > > It seems that one of examples in the documentation contains bug, namely: > http://doc.akka.io/docs/akka/2.4.7/java/stream/stream-graphs.html > >

Re: [akka-user] PersistenceQuery: Materialize view to datastore - When should the query stream be stopped?

I think some kind of tagging is the way to go. /Patrik On Sat, Jul 2, 2016 at 10:53 AM, Giovanni Alberto Caporaletti < paradi...@gmail.com> wrote: > Talking about the pattern in the subject >

[akka-user] Re: Using Actors to download a file from S3; only the first 12 actors work in parallel way, rest others work in a serialized manner. Why?

Problem with that code while loop - it is busy waiting inside Actor - it just consumes CPU, and does not do what you want. Instead pass instance of S3ProgressListener to txmanager.download(request, file_ref, listener) and handle listener changes there. Probably you will not get any speedup by go

[akka-user] Disassociation happening only in one direction (Akka 2.4.7)

We are using akka 2.4.7. Have two actor systems A and B. Association of actor system A -> B is being disassociated without any network issues. Same time the association A <- B is intact. Is there any config to change which can print the cause of change in the association state. R -- >>

[akka-user] Using Actors to download a file from S3; only the first 12 actors work in parallel way, rest others work in a serialized manner. Why?

Hi all, I am using Akka actors to download a file from S3. I create actors in a for loop and pass them 'start_byte' and 'end_byte'. Here is my code where I create the child actors: class AWS_Path_Receiver_Actor extends Actor{ def receive = { ??? ??? [some code] ???