Re: [akka-user] Re: Why does TestKit maintain the same ActorSystem between tests?

With persistence you need to clean the data, eg remove files if you use leveldb for testing. We have plenty of tests in the akka code base that does that. There is also community maintained in-mem journal for testing. See http://akka.io/community/ /Patrik fre 15 apr. 2016 kl. 23:16 skrev Spencer J

[akka-user] Code example of Akka Stream where Source is bulk data (records read in chunks)

Any example code that I can refer where stream Source is external service which gives bulk records in non reactive stream way, that we have to stream and manipulate the records via Flow and Sink it to DB? Which pattern of Akka stream we should use to make the Source? We can query External ser

[akka-user] Akka Singleton Cluster: resolveOnce of a worker by master fails after restart

down votefavorite I am using Akka Cluster 2.4.3 and trying to setup a simple cluster in my machine to understand its working better. I have a singleton cluster with r

[akka-user] Re: Why does TestKit maintain the same ActorSystem between tests?

Thanks Johan, That makes sense. I think when I'm not testing persistence it'll be no issue for me to keep the same actor system around. While testing persistence, however, it seems like a good idea to start fresh each time. I suppose if I keep using different actor names each time it'd probably

[akka-user] Re: In Akka how does cassandra react when it is full and cannot persist more messages

Thank you Patrik. On Friday, 8 April 2016 11:24:09 UTC-5, Amruta wrote: > > In Akka we are using cassandra to persist data. Does Akka automatically > cleanup cassandra based on timestamp of messages or do we need to manually > (in code) do it? If so any pointers would be helpful. > --

[akka-user] Akka Camel

Hi Friends, I am new to Akka group. I have a little bit knowledge on Apache Camel. I am having a simple job to transfer the files between 2 folders. It's a already completed alone on Apache camel. public static void main(String args[]) throws Exception { // create CamelContext

Re: [akka-user] In Akka how does cassandra react when it is full and cannot persist more messages

Akka does not automatically remove events. Event sourced systems normally keep all history, because it is important. Perhaps read up on some of the concepts. E.g. http://www.lagomframework.com/documentation/1.0.x/ES_CQRS.html /Patrik fre 8 apr. 2016 kl. 18:24 skrev Amruta : > In Akka we are usin

Re: [akka-user] Akka remote custom transport

I think replacing the transport is not going to end well. I'd recommend that you use Redis or whatever that is supported on that platform directly. You can still use actors locally on each node. /Patrik tors 14 apr. 2016 kl. 23:39 skrev Christoph Grotz : > Hi, > > I want to form a better understa

Re: [akka-user] AKKA persistence with big loading issue

also using routers for the consumers to consume the messages in multiple threads. On Friday, April 15, 2016 at 1:41:02 PM UTC-5, Patrik Nordwall wrote: > > What kind of flow control are you using? If you produce faster than > consumed you will quickly fill up memory and eventually be out of it.

Re: [akka-user] AKKA persistence with big loading issue

We will use throttling to control the rate. On Friday, April 15, 2016 at 1:41:02 PM UTC-5, Patrik Nordwall wrote: > > What kind of flow control are you using? If you produce faster than > consumed you will quickly fill up memory and eventually be out of it. > > /Patrik > > tors 14 apr. 2016 kl. 2

Re: [akka-user] AKKA persistence with big loading issue

What kind of flow control are you using? If you produce faster than consumed you will quickly fill up memory and eventually be out of it. /Patrik tors 14 apr. 2016 kl. 22:40 skrev Yan Pei : > It's better after I change to use persistAsync() instead of persist(). > What risk we might have to use

[akka-user] Re: akka-stream: How to define a Processor in Java

Hi Goufeng, I would recommend you to read up on GraphStage rather than the ActorSubscriber and ActorPublisher as it is a much more straight forward way to create custom stages. You can find a pretty thorough walkthrough of how it works and nice code samples in Java for GraphStage in the docs h

[akka-user] Re: Why does TestKit maintain the same ActorSystem between tests?

Hi Spencer, ActorSystems are semi-expensive, starting the dispatcher thread pool etc. on startup so this is the rationale for sharing one throughout the test. TestKit is built around this and will require a single actor system throughout the test. As there are no ties to any specific testing fr

Re: [akka-user] Akka dispatchers 80% cpu time spent in ForkJoinPool.scan() -> Unsafe.park()

Using Awaits a lot or just oversized the pool? -- Cheers, √ On Apr 15, 2016 7:33 PM, "dylan wilder" wrote: > As above. I'm using akka http and the service isn't scaling with the > number of simultaneous connections. I've also posted hear so I won't bother > writing up twice: > http://stackoverf

[akka-user] Akka dispatchers 80% cpu time spent in ForkJoinPool.scan() -> Unsafe.park()

As above. I'm using akka http and the service isn't scaling with the number of simultaneous connections. I've also posted hear so I won't bother writing up twice: http://stackoverflow.com/questions/36650077/akka-http-majority-of-cpu-time-spent-in-unsafe-park Any ideas?? My code paths barely ap

Re: [akka-user] Design query: using getContext().getChild() & stop()

You're welcome :) hope it helps. -Michael On 04/14/16 20:03, Mahesh Govind wrote: Thank you On Thu, Apr 14, 2016 at 10:19 PM, Michael Frank mailto:syntaxjoc...@gmail.com>> wrote: reply inline. hopefully this makes my solution more clear. -Michael On 04/14/16 02:37, Mahesh Go

[akka-user] Handling HTTPS with Akka-http

Hello, Is there any tutorial or example related to Https with akka-Http[java]? Thanks -- >> 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.g

Re: [akka-user] Future to CompletionStage

If you show a bit more context of what you are trying to achieve then we might be able to help you with that :-) Happy hakking, Roland > 15 apr 2016 kl. 13:05 skrev Federico Jakimowicz : > > Sure, well to be honest and I know this will not speak well about me... I got > a bit rusty so I need

Re: [akka-user] Future to CompletionStage

Sure, well to be honest and I know this will not speak well about me... I got a bit rusty so I need to catch up with Lambdas and some Java8 features. So I'm learning akka in the same time i'm catching up with java8. thanks a lot for your help El viernes, 15 de abril de 2016, 3:19:36 (UTC-3), rk

[akka-user] Re: activator-akka-distributed-workers-java - problem with master failover

Bringing this up again to see if there is anyone who has faced a similar issue or anyone who knows how to make the master failover use case work correctly. Thanks, Atul On Tuesday, 12 April 2016 17:17:16 UTC+5:30, Atul Deopujari wrote: > > Hi > I am yet unable to get the distributed-workers exa

Re: [akka-user] [akka-http] How to create custom Content-Type?

Here’s an example: https://github.com/hseeberger/akka-sse/blob/master/akka-sse/src/main/scala/de/heikoseeberger/akkasse/MediaTypes.scala#L30 -- Heiko Seeberger Home: heik