[akka-user] akka-persistence cassandra journal plugin api

2014-08-13 Thread ratika . prasad 
Hi,

I am using the journal plugin for akka persistnce as listed 
here https://github.com/krasserm/akka-persistence-cassandra/, however I see 
its mentioned that it works only with cassandra 2.0.3 and higer and we have 
cassandra in our project configured but of version 1.2.13.2, does that mean 
we would be unable to use this?

Post configuring the journal cassandra based plugin when I start our akka 
application I see below ( cassandra host that is configured has version 
less 2.0.3). Kindly help

akka.actor.ActorInitializationException: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:164) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.create(ActorCell.scala:596) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) 
~[akka-actor_2.10-2.3.4.jar:na]
at 
akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.dispatch.Mailbox.run(Mailbox.scala:219) 
~[akka-actor_2.10-2.3.4.jar:na]
at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
 
[akka-actor_2.10-2.3.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 
[scala-library-2.10.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
 
[scala-library-2.10.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 
[scala-library-2.10.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
 
[scala-library-2.10.4.jar:na]
Caused by: com.datastax.driver.core.exceptions.SyntaxError: line 2:29 
missing '=' at 'EXISTS'
at 
com.datastax.driver.core.exceptions.SyntaxError.copy(SyntaxError.java:35) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:256)
 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:172)
 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
akka.persistence.cassandra.journal.CassandraJournal.init(CassandraJournal.scala:52)
 
~[akka-persistence-cassandra_2.10-0.3.3.jar:0.3.3]
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method) ~[na:1.7.0_51]
at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
 
~[na:1.7.0_51]
at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
 
~[na:1.7.0_51]
at java.lang.reflect.Constructor.newInstance(Constructor.java:526) 
~[na:1.7.0_51]
at java.lang.Class.newInstance(Class.java:374) ~[na:1.7.0_51]
at akka.util.Reflect$.instantiate(Reflect.scala:45) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.NoArgsReflectConstructor.produce(Props.scala:361) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.Props.newActor(Props.scala:252) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.newActor(ActorCell.scala:552) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.create(ActorCell.scala:578) 
~[akka-actor_2.10-2.3.4.jar:na]
... 9 common frames omitted
com.datastax.driver.core.exceptions.SyntaxError: line 2:29 missing '=' at 
'EXISTS'
at 
com.datastax.driver.core.Responses$Error.asException(Responses.java:95) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:108)
 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:235) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:367) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:582)
 
~[cassandra-driver-core-2.0.3.jar:na]
at 
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
 
~[netty-3.9.0.Final.jar:na]
at 
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)
 
~[netty-3.9.0.Final.jar:na]
at 
org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendUpstream(DefaultChannelPipeline.java:791)
 
~[netty-3.9.0.Final.jar:na]
at

Re: [akka-user] akka-persistence cassandra journal plugin api

2014-08-13 Thread Konrad 'ktoso' Malawski 
Hello there,
I’m no cassandra guru but if something is implemented for 2.x I’d expect it not 
to work with 1.x.
Can you not use a newer version of cassandra?

— konrad

On 13 August 2014 at 17:42:04, ratika.pra...@razorthink.net 
(ratika.pra...@razorthink.net) wrote:

Hi,

I am using the journal plugin for akka persistnce as listed here 
https://github.com/krasserm/akka-persistence-cassandra/, however I see its 
mentioned that it works only with cassandra 2.0.3 and higer and we have 
cassandra in our project configured but of version 1.2.13.2, does that mean we 
would be unable to use this?

Post configuring the journal cassandra based plugin when I start our akka 
application I see below ( cassandra host that is configured has version less 
2.0.3). Kindly help

akka.actor.ActorInitializationException: exception during creation
        at akka.actor.ActorInitializationException$.apply(Actor.scala:164) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.actor.ActorCell.create(ActorCell.scala:596) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.dispatch.Mailbox.run(Mailbox.scala:219) 
~[akka-actor_2.10-2.3.4.jar:na]
        at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
 [akka-actor_2.10-2.3.4.jar:na]
        at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 
[scala-library-2.10.4.jar:na]
        at 
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
 [scala-library-2.10.4.jar:na]
        at 
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 
[scala-library-2.10.4.jar:na]
        at 
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
 [scala-library-2.10.4.jar:na]
Caused by: com.datastax.driver.core.exceptions.SyntaxError: line 2:29 missing 
'=' at 'EXISTS'
        at 
com.datastax.driver.core.exceptions.SyntaxError.copy(SyntaxError.java:35) 
~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:256)
 ~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:172)
 ~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52) 
~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36) 
~[cassandra-driver-core-2.0.3.jar:na]
        at 
akka.persistence.cassandra.journal.CassandraJournal.init(CassandraJournal.scala:52)
 ~[akka-persistence-cassandra_2.10-0.3.3.jar:0.3.3]
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native 
Method) ~[na:1.7.0_51]
        at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
 ~[na:1.7.0_51]
        at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
 ~[na:1.7.0_51]
        at java.lang.reflect.Constructor.newInstance(Constructor.java:526) 
~[na:1.7.0_51]
        at java.lang.Class.newInstance(Class.java:374) ~[na:1.7.0_51]
        at akka.util.Reflect$.instantiate(Reflect.scala:45) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.actor.NoArgsReflectConstructor.produce(Props.scala:361) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.actor.Props.newActor(Props.scala:252) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.actor.ActorCell.newActor(ActorCell.scala:552) 
~[akka-actor_2.10-2.3.4.jar:na]
        at akka.actor.ActorCell.create(ActorCell.scala:578) 
~[akka-actor_2.10-2.3.4.jar:na]
        ... 9 common frames omitted
com.datastax.driver.core.exceptions.SyntaxError: line 2:29 missing '=' at 
'EXISTS'
        at 
com.datastax.driver.core.Responses$Error.asException(Responses.java:95) 
~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:108)
 ~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:235) 
~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:367) 
~[cassandra-driver-core-2.0.3.jar:na]
        at 
com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:582)
 ~[cassandra-driver-core-2.0.3.jar:na]
        at 
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70)
 ~[netty-3.9.0.Final.jar:na]
        at 
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564)

Re: [akka-user] akka-persistence cassandra journal plugin api

2014-08-13 Thread Martin Krasser 


On 13.08.14 17:42, ratika.pra...@razorthink.net wrote:

Hi,

I am using the journal plugin for akka persistnce as listed 
here https://github.com/krasserm/akka-persistence-cassandra/, however 
I see its mentioned that it works only with cassandra 2.0.3 and higer 
and we have cassandra in our project configured but of version 
1.2.13.2, does that mean we would be unable to use this?


Yes, in this case you won't be able to use the Cassandra journal plugin. 
It doesn't support Cassandra 1.2.x.




Post configuring the journal cassandra based plugin when I start our 
akka application I see below ( cassandra host that is configured has 
version less 2.0.3). Kindly help


akka.actor.ActorInitializationException: exception during creation
at 
akka.actor.ActorInitializationException$.apply(Actor.scala:164) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.create(ActorCell.scala:596) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) 
~[akka-actor_2.10-2.3.4.jar:na]
at 
akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.dispatch.Mailbox.run(Mailbox.scala:219) 
~[akka-actor_2.10-2.3.4.jar:na]
at 
akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393) 
[akka-actor_2.10-2.3.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 
[scala-library-2.10.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) 
[scala-library-2.10.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 
[scala-library-2.10.4.jar:na]
at 
scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) 
[scala-library-2.10.4.jar:na]
Caused by: com.datastax.driver.core.exceptions.SyntaxError: line 2:29 
missing '=' at 'EXISTS'
at 
com.datastax.driver.core.exceptions.SyntaxError.copy(SyntaxError.java:35) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:256) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:172) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
akka.persistence.cassandra.journal.CassandraJournal.init(CassandraJournal.scala:52) 
~[akka-persistence-cassandra_2.10-0.3.3.jar:0.3.3]
at 
sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 
~[na:1.7.0_51]
at 
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) 
~[na:1.7.0_51]
at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 
~[na:1.7.0_51]
at 
java.lang.reflect.Constructor.newInstance(Constructor.java:526) 
~[na:1.7.0_51]

at java.lang.Class.newInstance(Class.java:374) ~[na:1.7.0_51]
at akka.util.Reflect$.instantiate(Reflect.scala:45) 
~[akka-actor_2.10-2.3.4.jar:na]
at 
akka.actor.NoArgsReflectConstructor.produce(Props.scala:361) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.Props.newActor(Props.scala:252) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.newActor(ActorCell.scala:552) 
~[akka-actor_2.10-2.3.4.jar:na]
at akka.actor.ActorCell.create(ActorCell.scala:578) 
~[akka-actor_2.10-2.3.4.jar:na]

... 9 common frames omitted
com.datastax.driver.core.exceptions.SyntaxError: line 2:29 missing '=' 
at 'EXISTS'
at 
com.datastax.driver.core.Responses$Error.asException(Responses.java:95) ~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:108) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:235) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.RequestHandler.onSet(RequestHandler.java:367) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
com.datastax.driver.core.Connection$Dispatcher.messageReceived(Connection.java:582) 
~[cassandra-driver-core-2.0.3.jar:na]
at 
org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:70) 
~[netty-3.9.0.Final.jar:na]
at 
org.jboss.netty.channel.DefaultChannelPipeline.sendUpstream(DefaultChannelPipeline.java:564) 
~[netty-3.9.0.Final.jar:na]
at