Kamon for Akka 2.3 is now available!

[Ivan Topolnjak]

Dear community,

We are happy to announce that Kamon 0.3.0, our latest release, is out and compatible with Akka 2.3! From now on, all of our releases will come in pairs and aligned with the following Akka versions:

• 0.3.x releases are compatible with Akka 2.3, Spray 1.3 and Play 2.3-M1.
• 0.2.x releases are compatible with Akka 2.2, Spray 1.2 and Play 2.2.

The 0.3.0/0.2.0 releases contain exactly the same feature set as our 0.0.15 release, we just made the necessary changes to make it compatible with Akka 2.3. If you were waiting for this release, then go and get started right away!

[per.j.j...@gmail.com]

Hi,

I tried 0.3.0 (using StatsD) and akka 2.3.2 (cluster).

I got this exception:

2014-04-26 10:52:32,908 ERROR akka.remote.EndpointWriter akka.tcp://PlanS...@127.0.0.1:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FClientSystem%40127.0.0.1%3A56435-1/endpointWriter - Transient association error (association remains live)
java.io.NotSerializableException: kamon.trace.TraceContextAware$DefaultTraceContextAware
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183) ~[na:1.7.0_55]
at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1547) ~[na:1.7.0_55]
at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1508) ~[na:1.7.0_55]
at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1431) ~[na:1.7.0_55]
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1177) ~[na:1.7.0_55]
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347) ~[na:1.7.0_55]
at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply$mcV$sp(Serializer.scala:129) ~[akka-actor_2.10-2.3.2.jar:na]
at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:129) ~[akka-actor_2.10-2.3.2.jar:na]
at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:129) ~[akka-actor_2.10-2.3.2.jar:na]
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57) ~[scala-library-2.10.3.jar:na]
at akka.serialization.JavaSerializer.toBinary(Serializer.scala:129) ~[akka-actor_2.10-2.3.2.jar:na]
at akka.remote.MessageSerializer$.serialize(MessageSerializer.scala:36) ~[akka-remote_2.10-2.3.2.jar:na]
at akka.remote.EndpointWriter$$anonfun$akka$remote$EndpointWriter$$serializeMessage$1.apply(Endpoint.scala:713) ~[akka-remote_2.10-2.3.2.jar:na]
at akka.remote.EndpointWriter$$anonfun$akka$remote$EndpointWriter$$serializeMessage$1.apply(Endpoint.scala:713) ~[akka-remote_2.10-2.3.2.jar:na]
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57) ~[scala-library-2.10.3.jar:na]
at akka.remote.EndpointWriter.akka$remote$EndpointWriter$$serializeMessage(Endpoint712) ~[akka-remote_2.10-2.3.2.jar:na]
at akka.remote.EndpointWriter$$anonfun$7.applyOrElse(Endpoint.scala:594) ~[akka-remote_2.10-2.3.2.jar:na]
at akka.remote.EndpointWriter$$anonfun$7.applyOrElse(Endpoint.scala:581) ~[akka-remote_2.10-2.3.2.jar:na]
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33) ~[scala-library-2.10.3.jar:na]
at akka.actor.FSM$class.processEvent(FSM.scala:604) ~[akka-actor_2.10-2.3.2.jar:na]
at akka.remote.EndpointWriter.processEvent(Endpoint.scala:479) ~[akka-remote_2.10-2.3.2.jar:na]
at akka.actor.FSM$class.akka$actor$FSM$$processMsg(FSM.scala:598) ~[akka-actor_2.10-2.3.2.jar:na]
at akka.actor.FSM$$anonfun$receive$1.applyOrElse(FSM.scala:592) ~[akka-actor_2.10-2.3.2.jar:na]
at akka.actor.Actor$class.aroundReceive(Actor.scala:465) ~[akka-actor_2.10-2.3.2.jar:na]
at akka.remote.EndpointActor.aroundReceive(Endpoint.scala:409) ~[akka-remote_2.10-2.3.2.jar:na]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) [akka-actor_2.10-2.3.2.jar:na]
at akka.actor.ActorCell.invoke_aroundBody0(ActorCell.scala:487) [akka-actor_2.10-2.3.2.jar:na]
at akka.actor.ActorCell$AjcClosure1.run(ActorCell.scala:1) [akka-actor_2.10-2.3.2.jar:na]
at org.aspectj.runtime.reflect.JoinPointImpl.proceed(JoinPointImpl.java:149) [aspectjweaver-1.7.4.jar:1.7.4]
at akka.instrumentation.BehaviourInvokeTracing$$anonfun$aroundBehaviourInvoke$1.apply(ActorMessagePassingTracing.scala:55) [kamon-core-0.3.0.jar:0.3.0]
at kamon.trace.TraceRecorder$.withTraceContext(TraceRecorder.scala:66) [kamon-core-0.3.0.jar:0.3.0]
at akka.instrumentation.BehaviourInvokeTracing.aroundBehaviourInvoke(ActorMessagePassingTracing.scala:54) [kamon-core-0.3.0.jar:0.3.0]
at akka.actor.ActorCell.invoke(ActorCell.scala:483) [akka-actor_2.10-2.3.2.jar:na]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) [akka-actor_2.10-2.3.2.jar:na]
at akka.dispatch.Mailbox.run(Mailbox.scala:220) [akka-actor_2.10-2.3.2.jar:na]
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(Abstracther.scala:393) [akka-actor_2.10-2.3.2.jar:na]
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [scala-library-2.10.3.jar:na]
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [scala-library-2.10.3.jar:na]
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [scala-library-2.10.3.jar:na]
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [scala-library-2.10.3.jar:na]

Anything I can do to fix that?

/Per

On Friday, 25 April 2014 02:16:02 UTC+1, Ivan Topolnjak wrote:
> Dear community,
>
>
> We are happy to announce that Kamon 0.3.0, our latest release, is out and compatible with Akka 2.3! From now on, all of
> our releases will come in pairs and aligned with the following Akka versions:
>

> 0.3.x releases are compatible with Akka 2.3, Spray 1.3 and Play 2.3-M1.0.2.x releases are compatible with Akka 2.2, Spray 1.2 and Play 2.2.

[Diego Parra]

Hi, Per

currently kamon does not have support for akka cluster, but this in our roadmap.

best regards!

[per.j.j...@gmail.com]

Ok, I'll read the docs next time before I paste stack traces :)

/Per

[Ivan Topolnjak]

Per,

I'm sorry that at the moment we can't offer support for cluster/remoting and as Diego mentioned we have it on our roadmap.. We will let you know as soon as we have something working and hopefully you can help us test it :).. thanks for trying Kamon and I hope that you have some other non-cluster apps where Kamon can be useful right away, best regards!

--
You received this message because you are subscribed to the Google Groups "kamon-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to kamon-user+...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[rampall...@gmail.com]

Hi Ivan,

I tried making this work with scala 2.11, it gave Conflicting cross version suffixes error. Wanted to know if scala 2.11 support is on the roadmap in near future.

Thank you
Srinivas

[Diego Parra]

Hi,
currently kamon does not have support for scala 2.11, but this in our roadmap.

best regards!

[Ivan Topolnjak]

Per,

I tried to do a couple tests using the akka-cluster to figure out what we would need to do to support it and what I see from simple messages is that they just work, I guess that you had a more complex example.. is it possible for you to share a bit of the code that generated the exception you posted for us to test?

[per.j.j...@gmail.com]

On Wednesday, 9 July 2014 20:12:17 UTC+1, Ivan Topolnjak wrote:
> Per,
>
> I tried to do a couple tests using the akka-cluster to figure out what we would need to do to support it and what I see from simple messages is that they just work, I guess that you had a more complex example.. is it possible for you to share a bit of the code that generated the exception you posted for us to test?

Hi Ivan,

Saw your question today. I don't have a minimum example to share with you right now but here is the setup:

* Akka 2.3.3 (Scala 2.11)
* kamon-core 0.3.1 (Scala 2.11)
* kamon-statsd 0.3.1 (Scala 2.11)

1. Starting a cluster
2. Starting a cluster sharding actor (using the cluster sharding extension)
3. Registering the sharding actor as 'receptionist'.
4. Sending a message to the cluster using akka.contrib.pattern.ClusterClient

Get the same stacktrace as last time:

2014-07-14 22:34:08,286 ERROR akka.remote.EndpointWriter akka.tcp://PlanS...@127.0.0.1:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FClientSystem%40127.0.0.1%3A37827-1/endpointWriter - Transient association error (association remains live)
java.io.NotSerializableException: kamon.trace.TraceContextAware$DefaultTraceContextAware
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1183) ~[na:1.7.0_60]
at java.io.ObjectOutputStream.defaultWriteFields(ObjectOutputStream.java:1547) ~[na:1.7.0_60]
at java.io.ObjectOutputStream.writeSerialData(ObjectOutputStream.java:1508) ~[na:1.7.0_60]
at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1431) ~[na:1.7.0_60]
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1177) ~[na:1.7.0_60]
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:347) ~[na:1.7.0_60]
at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply$mcV$sp(Serializer.scala:129) ~[akka-actor_2.11-2.3.3.jar:na]
at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:129) ~[akka-actor_2.11-2.3.3.jar:na]
at akka.serialization.JavaSerializer$$anonfun$toBinary$1.apply(Serializer.scala:129) ~[akka-actor_2.11-2.3.3.jar:na]
at scala.util.DynamicVariable.withValue(DynamicVariable.scala:58) ~[scala-library-2.11.1.jar:na]
at akka.serialization.JavaSerializer.toBinary(Serializer.scala:129) ~[akka-actor_2.11-2.3.3.jar:na]
at akka.remote.MessageSerializer$.serialize(MessageSerializer.scala:36) ~[akka-remote_2.11-2.3.3.jar:na]
at akka.remote.EndpointWriter$$anonfun$serializeMessage$1.apply(Endpoint.scala:845) ~[akka-remote_2.11-2.3.3.jar:na]

[jos...@evernym.us]

This issue still exists on kamon 0.3.4. Does kamon support akka remoting and cluster yet?

[Ivan Topolnjak]

Hey, for the record: since Kamon 0.3.5 we have basic support for remoting and cluster!