Re: [akka-user] Problem with Akka 2.4 Snapshot and Play Framework 2.3.8

Okay, I will see if we can update to 1.8 from 1.7. Thanks for the detailed explanation. Vaughn -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives: https:/

Re: [akka-user] Getting started Akka-Http?

Akka http reached 1.0 so look for the 1.0 docs, instead of 1.0-M2 ;-) Correct link: http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0/scala/http/client-side/index.html Read more about the release here: http://akka.io/news/2015/07/15/akka-streams-1.0-released.html Happy hakking! On Ju

Re: [akka-user] Problem with Akka 2.4 Snapshot and Play Framework 2.3.8

Hi Vaughn, Akka 2.4 is finally dropping java 6 support and requires java 8. It's more than just being compiled with 8, it actually uses types and APIs only available in 7+. Java 6 has been end of lifed a very long time ago. Java 7 actually as well since April this year, except fixes for customers

[akka-user] Getting started Akka-Http?

Hello I am new to Akka and want to expose actors via REST endpoint. I learnt that akka-http reached 1.0, so thought of learning it. When I look a the documentation however, they are incomplete http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/http/client.html How do I get s

[akka-user] Problem with Akka 2.4 Snapshot and Play Framework 2.3.8

I confirmed that Akka 2.4 snapshot is compiled with Java 1.8. Is there any way to get 2.4 compiled with Java 1.7? Not sure that Java 1.8 can be used in production. Vaughn -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs

[akka-user] Problem with Akka 2.4 Snapshot and Play Framework 2.3.8

Hey, I have been running Play 2.3.8 with Akka 2.3.9 and all works fine. However, I now need to use Akka Persistence and so am getting dependencies for the Akka 2.4 Snapshot. With this I have started getting exceptions on Play start up: UnsupportedClassVersionError: ... com/typesafe/config/C

[akka-user] Re: memory issue in akka application

Hi, Thanks for the response. Actually we are not creating any separate actor for log (unless akka creates internally). How do we identify the actor? The way we are trying to write logs is pretty much same as defined in akka documentation (http://doc.akka.io/docs/akka/2.0/java/logging.html) alon

[akka-user] Re: memory issue in akka application

Hi Somak, this seems like an Actor isn't keeping pace with its incoming messages. You can try to follow references from the mail box to the actor instance to find out which actor it is. As you are talking about log message my guess would be that your logging actor is too slow writing logs to di

[akka-user] Beginner help with Remote Node/JVM Testing

Hello there, I have been learning Akka and as part of my project I wanted to run the test for my usecase, I need help with it Github link for my code sample *Scenario* 1. I have 2 Actor Systems - ProcessingSystem and ConnectorSystem.

Re: [akka-user] Remote Actor Starting locally

Thank you Heiko For me it turned out that the code and configuration was all correct, just that sbt was not run again and causing this issue + Harit On Thursday, July 23, 2015 at 10:02:10 PM UTC-7, Heiko Seeberger wrote: > > The path of the actor in the config must match the path of the actor in

[akka-user] memory issue in akka application

We have an application in Akka and having a problem with increasing heap memory that is growing with time and eventually crashing the application. On analyzing the heap dump we can see all our log entries are getting persisted in the memory. Below is object tree for the same Akka dispatcher -

Re: [akka-user] Re: akka streams - for comprehension counterpart

On Wed, Jul 15, 2015 at 9:20 AM, wrote: > Sorry. I still cannot grip the point on how to pass errors or maybe > exceptions down the stream in a neat way without stopping the stream. > Use Try, Either, Option or any other (possibly self-defined) disjoint union type. > Swallowing errors (includi

[akka-user] Re: Implicit value issue for FromRequestUnmarshaller in akka-http with spray-json

Hi Heiko, Here is my code implicit val system = ActorSystem() implicit val executor: ExecutionContext = system.dispatcher val log: LoggingAdapter = Logging(system, getClass) implicit val materializer = ActorMaterializer() Http().bindAndHandle(routes, httpInterface, httpPort)

Re: [akka-user] Re: Akka Persistence, Cassandra and compaction strategies (DTCS)

My PoV is that if an event doesn't have any current nor potential future value then why persist it in the first case (i.e. "am I being too granular here?"), otherwise I assume that storing it indefinitely will be valuable since it can be used for all sorts of analytics down the line. On Fri, Jul 2

[akka-user] TestKit ignore dilation for expectNoMsg?

Hi all, Is it possible to override / bypass the time dilation introduced by the akka.test.timefactor for some tests? I do some expectNoMsg tests in loops which is fine without dilation, but when running on a really slow CI machine it introduces a lot of waiting with very little value... I reall

Re: [akka-user] Re: Akka Persistence, Cassandra and compaction strategies (DTCS)

But this is just one single actor in a much bigger system... In total the event log is growing with 4 GB each day. This is, however, not optmized at all, and we could probably save a lot of space by being smarter about what we persist... I see no reason to leave the data in the event log, as we h

Re: [akka-user] Re: Akka Persistence, Cassandra and compaction strategies (DTCS)

20k/h is 5.5 per second and given about 1kb per event, that is about 20mb per hour, this is 480mb per day, which is about 171gb per year, which, according to this means that it will cost you about $5.13 per year (going down). Given compression, you c

[akka-user] Re: Akka Persistence, Cassandra and compaction strategies (DTCS)

I do delete after snapshot, so the functionality is intact. What do you do about disk usage, and startup time? These actors never die, so the event log would grow by 20'000 events each hour forever... Anders On 24 July 2015 at 05:25, Vaughn Vernon wrote: > As a rule you should never delete mess

[akka-user] Re: Akka-http websockets connection fails 95% of the time

Hi Luc, I'd like to get to the bottom of this problem to make sure we find the problem if there's one in akka-http. Could you provide an executable reproduction? Johannes On Thursday, July 23, 2015 at 3:05:29 PM UTC+2, Luc Klaassen wrote: > > Hello all, > > I'm having trouble setting up a basi

[akka-user] Re: testing akka cluster on Blue Waters @ NCSA

Hi Boris, My first attempt was to adapt the Distributed Workers with Akka and Scala > example > just to see how that performs "out of the box". In the process I've also > had to find a solution to be able to get the applicati

[akka-user] Re: Implicit value issue for FromRequestUnmarshaller in akka-http with spray-json

I agree, this is more confusing than necessary. I created https://github.com/akka/akka/issues/18064 to improve the situation. Johannes On Thursday, July 23, 2015 at 3:27:07 PM UTC+2, Kabir Idris wrote: > > Hi all, Im facing the same error in akka-http 1.0 > > > > On Monday, March 16, 2015 at 12

Re: [akka-user] Re: Akka Cluster ⇒ AssociationError Error [Invalid address]

I just posted a similar question. I want to know when a node is quarantined in code so we can auto-restart. The node gets quarantined due to auto-down so you can bump up auto-down-unreachable-after or just disable it. If you're cluster is mainly static and you don't commonly add new nodes then

[akka-user] How to recover from network partition quarantine

During a network partition, the partitioned node is removed from the cluster after auto-down occurs and quarantined such that it must restarted in order to rejoin the cluster once the partition heals. A manual restart due to a temporary network outage is problematic when one is developing a com