[akka-user] Nestling Akka schedulers hangs reload inside Play

2014-06-19 Thread Anton Fagerberg
I'm using Akka with Play Framework and recently updated to Play Framework 2.3 (which uses Akka 2.3.3). In my code I have a piece which nestles Akka schedulers, something like this: Akka.system.scheduler.schedule(0 seconds, 20 seconds) { Akka.system.scheduler.scheduleOnce(3 seconds) {

Re: [akka-user] akka debug stream eventually filling up the memory?

2014-06-19 Thread Patrik Nordwall
I thought a bit harder about this issue, and have come up with a nice solution that will filter log events based on slf4j (logback) config before they are published to the event stream. Pull request here: https://github.com/akka/akka/pull/15413 Cheers, Patrik On Wed, Jun 11, 2014 at 1:38 PM,

[akka-user] Java 8 - Mapper as a functional interface?

2014-06-19 Thread Chanan Braunstein
Hello, Right now akka.dispatch.MapperT,R cannot be used as a Java 8 lambda because it is not a functional interface. Any chance that might change in a future version of Akka? Chanan. -- Read the docs: http://akka.io/docs/ Check the FAQ:

Re: [akka-user] Java 8 - Mapper as a functional interface?

2014-06-19 Thread √iktor Ҡlang
This will be solved in Scala 2.12 when Scala FunctionN will be Functional Interfaces (i.e. there's no need for akka.dispatch.Mapper any longer). On Thu, Jun 19, 2014 at 1:20 PM, Chanan Braunstein chanan.braunst...@pearson.com wrote: Hello, Right now akka.dispatch.MapperT,R cannot be used as

Re: [akka-user] Java 8 - Mapper as a functional interface?

2014-06-19 Thread Chanan Braunstein
Great news! And of course the followup question, do you have an estimate of when that may happen? :) On Thursday, June 19, 2014 7:25:21 AM UTC-4, √ wrote: This will be solved in Scala 2.12 when Scala FunctionN will be Functional Interfaces (i.e. there's no need for akka.dispatch.Mapper any

Re: [akka-user] Java 8 - Mapper as a functional interface?

2014-06-19 Thread √iktor Ҡlang
2.12 is preliminarily scheduled for early 2016. But if you aren't keen on waiting until then, if you're depending on Java8, you can very easily create static methods that take Java8 Function and BiFunction etc and creates akka.dispatch.Mapper (and friends) and returns them. But speaking of

Re: [akka-user] I just updated to Akka 2.3.3

2014-06-19 Thread Konrad Malawski
Hello Troy, Welcome to 2.3.3 :-) Please refer to the cluster docs about Cluster Metrics http://doc.akka.io/docs/akka/2.3.3/scala/cluster-usage.html#cluster-metrics to understand what that is used for. Basically, the JVM does not provide very detailed information via JMX which might be used by for

[akka-user] Re: akka debug stream eventually filling up the memory?

2014-06-19 Thread Ryan Tanner
Unrelated to the OP's issue, but so long as we're discussing logback, a problem we've always had with logback is it's own debug output during multi-JVM cluster tests. Logback outputs its status info for every JVM in the test. Multiple times. No one on our team has been able to get it to

[akka-user] question about akka mailbox

2014-06-19 Thread simafengyun
hi all, If an actor A's mailbox is full. What will happen when another actor B still sends message to it? Will the message be missed? Or the actor B will wait until the message is add to A's mailbox? By the way, which scenarios message will be missed in akka system when Delivery? --

[akka-user] Re: question about akka mailbox

2014-06-19 Thread Luis Medina
Hello, Per the documentation (http://doc.akka.io/docs/akka/2.3.3/java/mailboxes.html) it appears that the default mailbox of an actor is unbounded in size which I take it to mean that it will store as many things as it can fit in the memory of the machine it's running on. If you try giving it

[akka-user] ZeroMQ Push/Pull examples for Akka

2014-06-19 Thread JL Marizan
Hi team, I was reading the documentation about how to use ZeroMQ Push/Pull connections with Akka but it is really limited ( http://doc.akka.io/docs/akka/snapshot/scala/zeromq.html#Push-Pull_Connection). How do I prepare a specified actor to receive messages through a ZeroMQ push connection? It

[akka-user] ClassnotFound exception in IntelliJ: akka.actor.ActorSystem

2014-06-19 Thread S. Zhou
I am new to Akka. We use SBT to compile Scala. After use gen-idea, I import the scala (which use akka) project. However, when I run the project inside Intellij, I got the following exceptions. Not sure how to fix it. BTW, I use akka 2.2.4 Caused by: java.lang.ClassNotFoundException:

[akka-user] DI/Service Locator via Akka Extension, anyone else doing this?

2014-06-19 Thread Scott Clasen
I stumbled on to a DI/Service locator pattern yesterday, using an extension as the ‘application context’ if you will. Something along the lines of trait Dependencies{ def serviceA : ActorRef def serviceB: ServiceTrait } case class DI(system: ExtendedActorSystem) extends Extension

Re: [akka-user] [Akka remote]

2014-06-19 Thread Felipe Dezotti
Hello again, I did some changes, but I am still facing the same problem. As I am kind of new in Akka, maybe I am missing something. So, here is the current situation: - Virtual machine 1: * Glassfish with my application deployed with this configuration file: akka { actor