Hi, I wonder if anyone have any Java Client or any client that truely works with Event Store?
I have tried with the JVM Java Client: https://github.com/EventStore/EventStore.JVM
But I get problems all the time when I´m trying to use it. I get problems with the akka-connection.
I need a client that can write to and read from Event Store.
I also want it to save the data from the Event Store in XML, JSON or any other format.
Can anyone help me with this?
King regards
Johan
The jvm client should be working. What version of the client/backend are you trying to run together? There is significant code coverage on it in tests.
Are you saying you have never gotten it working? Can you post the code you are using with it perhaps?
As an alternative you can quite easily just use the atom interface from any language (it is just http).
Cheers,
Greg
I´m using Event Store 2.0.1 and I´m using all the JAR-files for akka 2.2.4.
I also use the eventstore-client_2.10-0.3.0.jar file. Is this the wrong JAR-file?
Yes I have never got it working:
Here´s the code for the reading function:
package eventstore.j.examples;
import akka.actor.;
import akka.actor.Status.Failure;
import akka.event.;
import eventstore.;
import eventstore.j.;
import eventstore.tcp.ConnectionActor;
import java.net.InetSocketAddress;
public class ReadEventExample {
public static void main(String[] args) {
final ActorSystem system = ActorSystem.create();
final Settings settings = new SettingsBuilder()
.address(new InetSocketAddress("127.0.0.1", 1113))
.defaultCredentials("admin", "changeit")
.build();
final ActorRef connection = system.actorOf(ConnectionActor.getProps(settings));
final ActorRef readResult = system.actorOf(Props.create(ReadResult.class));
final ReadEvent readEvent = new ReadEventBuilder("my-stream")
.first()
.resolveLinkTos(false)
.requireMaster(true)
.build();
connection.tell(readEvent, readResult);
}
public static class ReadResult extends UntypedActor {
final LoggingAdapter log = Logging.getLogger(getContext().system(), this);
public void onReceive(Object message) throws Exception {
if (message instanceof ReadEventCompleted) {
final ReadEventCompleted completed = (ReadEventCompleted) message;
final Event event = completed.event();
log.info("event: {}", event);
} else if (message instanceof Failure) {
final Failure failure = ((Failure) message);
final EsException exception = (EsException) failure.cause();
log.error("reason: {}, message: {}", exception.reason(), exception.message());
} else
unhandled(message);
context().system().shutdown();
}
}
}
Okay where can I use the atom interface?
I get this answer then I´m executing the code:
[INFO] [04/18/2014 13:44:10.591] [default-akka.actor.default-dispatcher-3] [akka://default/user/$a] connecting to /127.0.0.1:1113
[INFO] [04/18/2014 13:44:10.647] [default-akka.actor.default-dispatcher-3] [akka://default/user/$a] connected to /127.0.0.1:1113
Uncaught error from thread [default-akka.actor.default-dispatcher-4] shutting down JVM since ‘akka.jvm-exit-on-fatal-error’ is enabled for ActorSystem[default]
java.lang.NoClassDefFoundError: net/sandrogrzicic/scalabuff/Parser
[ERROR] [04/18/2014 13:44:10.693] [default-akka.actor.default-dispatcher-4] [ActorSystem(default)] Uncaught error from thread [default-akka.actor.default-dispatcher-4] shutting down JVM since ‘akka.jvm-exit-on-fatal-error’ is enabled
at java.lang.ClassLoader.defineClass1(Native Method)
java.lang.NoClassDefFoundError: net/sandrogrzicic/scalabuff/Parser
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass( at java.lang.ClassLoader.defineClass(ClassLoader.java:791ClassLoader.java:791)
)
at java.security.SecureClassLoader.defineClass( at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:449 at java.net.URLClassLoader.defineClass()
URLClassLoader.java:449)
at java.net.URLClassLoader.access$100(URLClassLoader.java:71)
at java.net.URLClassLoader.access$100(URLClassLoader.java:71)
at java.net.URLClassLoader$1.run(URLClassLoader.java:361 at java.net.URLClassLoader$1.run()
URLClassLoader.java:361)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass( at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass( at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
ClassLoader.java:356)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:171)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:171)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:170)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:170)
at eventstore.proto.DefaultProtoFormats$ProtoWriter$class.write(DefaultProtoFormats.scala:45)
at eventstore.proto.DefaultProtoFormats$ProtoWriter$class.write(DefaultProtoFormats.scala:45)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.write(EventStoreProtoFormats.scala:170)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.write(EventStoreProtoFormats.scala:170)
at eventstore.tcp.MarkerByte$.eventstore$tcp$MarkerByte$$writeMessage$1(MarkerByte.scala:74)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.MarkerByte$.eventstore$tcp$MarkerByte$$writeMessage$1(MarkerByte.scala:74)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:66)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:58)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:66)
at eventstore.util.BytesWriter$class.toByteString(BytesFormat.scala:18)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:58)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.toByteString(EventStoreFormats.scala:58)
at eventstore.util.BytesWriter$class.toByteString(BytesFormat.scala:18)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.toByteString(EventStoreFormats.scala:58)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at scala.util.Try$.apply(Try.scala:161)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at akka.io.PipelineFactory$$anon$6.injectCommand(Pipelines.scala:323)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at akka.io.TcpPipelineHandler$$anonfun$receive$1.applyOrElse(TcpPipelineHandler.scala:151)
at scala.util.Try$.apply(Try.scala:161)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:498)
at akka.io.PipelineFactory$$anon$6.injectCommand(Pipelines.scala:323)
at akka.actor.ActorCell.invoke(ActorCell.scala:456)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237)
at akka.io.TcpPipelineHandler$$anonfun$receive$1.applyOrElse(TcpPipelineHandler.scala:151)
at akka.dispatch.Mailbox.run(Mailbox.scala:219)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:498)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:385)
at akka.actor.ActorCell.invoke(ActorCell.scala:456)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237)
at akka.dispatch.Mailbox.run(Mailbox.scala:219)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:385)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
Caused by: java.lang.ClassNotFoundException: net.sandrogrzicic.scalabuff.Parser
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
Caused by: java.lang.ClassNotFoundException: net.sandrogrzicic.scalabuff.Parser
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.lang.ClassLoader.loadClass( at java.security.AccessController.doPrivileged(Native Method)
ClassLoader.java:356)
… 45 more
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
... 45 more
Java Result: -1
BUILD SUCCESSFUL (total time: 1 second)
Try running with 3.0 on website instead of 2.0.1
As for the atom interface start here https://github.com/eventstore/eventstore/wiki/Getting-Started-HTTP
You can find quite a few other docs on it here under http api https://github.com/eventstore/eventstore/wiki it is just http requests that go back and forth so can be used from basically any language.
Uncaught error from thread [default-akka.actor.default-dispatcher-4] shutting down JVM since ‘akka.jvm-exit-on-fatal-error’ is enabled for ActorSystem[default]
java.lang.NoClassDefFoundError: net/sandrogrzicic/scalabuff/Parser
This looks like a config error (like some things not in path etc)
As you can see you are missing some transitive dependencies on scalabuff. I'm really curious on how did it happen
I tried with Event Store 3.0 but I got the same exception.
I get this expection in cmd when I´m trying to connect to the Event Store when I´m using akka 2.2.4 and with the Java-code from ReadEventExample.java:
[10720,11,12:43:25.730] Connection ‘external-normal’ [127.0.0.1:7292, {45e64cc3-
91b3-4e80-8e6e-f23fc678050b}] closed: ConnectionReset.
[10720,11,12:44:07.845] External TCP connection accepted: [Normal, 127.0.0.1:729
7, L127.0.0.1:1113, {096679e1-440c-4288-aab0-494aba71119d}].
[10720,11,12:44:08.229] ES TcpConnection closed [12:44:08.229: N127.0.0.1:7297,
L127.0.0.1:1113, {096679e1-440c-4288-aab0-494aba71119d}]:
Received bytes: 0, Sent bytes: 0
Send calls: 0, callbacks: 0
Receive calls: 1, callbacks: 1
Close reason: [ConnectionReset] Socket receive error
[10720,11,12:44:08.229] Connection ‘external-normal’ [127.0.0.1:7297, {096679e1-
440c-4288-aab0-494aba71119d}] closed: ConnectionReset.
I get this exception in NetBeans when I´m using akka 2.3.2 instead of akka 2.2.4 and when I´m trying to use the ReadEventExample:
[ERROR] [04/20/2014 14:47:20.807] [default-akka.actor.default-dispatcher-5] [akka://default/user/$a] null
akka.actor.ActorInitializationException: exception during creation
at akka.actor.ActorInitializationException$.apply(Actor.scala:164)
at akka.actor.ActorCell.create(ActorCell.scala:596)
at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456)
at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478)
at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263)
at akka.dispatch.Mailbox.run(Mailbox.scala:219)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:525)
at akka.util.Reflect$.instantiate(Reflect.scala:66)
at akka.actor.ArgsReflectConstructor.produce(Props.scala:349)
at akka.actor.Props.newActor(Props.scala:249)
at akka.actor.ActorCell.newActor(ActorCell.scala:552)
at akka.actor.ActorCell.create(ActorCell.scala:578)
… 9 more
Caused by: java.lang.NoClassDefFoundError: akka/io/PipelineStage
at eventstore.tcp.ConnectionActor.(ConnectionActor.scala:47)
… 18 more
Caused by: java.lang.ClassNotFoundException: akka.io.PipelineStage
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
… 19 more
[INFO] [04/20/2014 14:47:20.813] [default-akka.actor.default-dispatcher-5] [akka://default/user/$a] Message [eventstore.ReadEvent] from Actor[akka://default/user/$b#1186501278] to Actor[akka://default/user/$a#630371313] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings ‘akka.log-dead-letters’ and ‘akka.log-dead-letters-during-shutdown’.
Please do not use JVM client 0.3.0 with Event Store 3.0RC2.
0.3.0 will work nicely with Event Store 2.0.1
Yes, expected,
Event Store JVM client 0.3.0 doesn’t work with Akka 2.3.x… I’ll update README about this.
Please try with Akka 2.2.4
Okay thanks.
I first tried with eventstore-client_2.10-0.3.0.jar but I get exceptions.
Then I found this files on the internet:
eventstore-client_2.10-0.3.1.jar
eventstore-client_2.10-0.3.1-javadoc.jar
eventstore-client_2.10-0.3.1-sources.jar
I´m now using this files but i get the same exceptions.
When I´m using akka 2.2.4, I get this exception from NetBeans when I´m using ReadEventExample.java code:
run:
[INFO] [04/20/2014 16:39:12.247] [default-akka.actor.default-dispatcher-3] [akka://default/user/$a] connecting to /127.0.0.1:1113
[INFO] [04/20/2014 16:39:12.301] [default-akka.actor.default-dispatcher-3] [akka://default/user/$a] connected to /127.0.0.1:1113
Uncaught error from thread [default-akka.actor.default-dispatcher-4] shutting down JVM since ‘akka.jvm-exit-on-fatal-error’ is enabled for ActorSystem[default]
java.lang.NoClassDefFoundError: net/sandrogrzicic/scalabuff/Parser
at java.lang.ClassLoader.defineClass1(Native Method)
[ERROR] [04/20/2014 16:39:12.348] [default-akka.actor.default-dispatcher-4] [ActorSystem(default)] Uncaught error from thread [default-akka.actor.default-dispatcher-4] shutting down JVM since ‘akka.jvm-exit-on-fatal-error’ is enabled
java.lang.NoClassDefFoundError: net/sandrogrzicic/scalabuff/Parser
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass( at java.lang.ClassLoader.defineClass(ClassLoader.java:791)
ClassLoader.java:791)
at java.security.SecureClassLoader.defineClass( at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142SecureClassLoader.java:142)
)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)
at java.net.URLClassLoader.access$100(URLClassLoader.java:71)
at java.net.URLClassLoader.access$100(URLClassLoader.java:71)
at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423 at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass( at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
ClassLoader.java:356)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:171)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:171)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:170)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.toProto(EventStoreProtoFormats.scala:170)
at eventstore.proto.DefaultProtoFormats$ProtoWriter$class.write(DefaultProtoFormats.scala:45)
at eventstore.proto.DefaultProtoFormats$ProtoWriter$class.write(DefaultProtoFormats.scala:45)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.write(EventStoreProtoFormats.scala:170)
at eventstore.tcp.EventStoreProtoFormats$ReadEventWriter$.write(EventStoreProtoFormats.scala:170)
at eventstore.tcp.MarkerByte$.eventstore$tcp$MarkerByte$$writeMessage$1(MarkerByte.scala:74)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.MarkerByte$.eventstore$tcp$MarkerByte$$writeMessage$1(MarkerByte.scala:74)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:66)
at eventstore.tcp.MarkerByte$$anonfun$writer$2.apply(MarkerByte.scala:76)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:58)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:66)
at eventstore.util.BytesWriter$class.toByteString(BytesFormat.scala:18)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.toByteString(EventStoreFormats.scala:58)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.write(EventStoreFormats.scala:58)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at eventstore.util.BytesWriter$class.toByteString(BytesFormat.scala:18)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at eventstore.tcp.EventStoreFormats$TcpPackageOutWriter$.toByteString(EventStoreFormats.scala:58)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at eventstore.tcp.MessageByteStringAdapter$$anon$1$$anonfun$1.apply(MessageByteStringAdapter.scala:12)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at scala.util.Try$.apply(Try.scala:161)
at akka.io.PipelineFactory$$anon$6.injectCommand(Pipelines.scala:323)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.io.TcpPipelineHandler$$anonfun$receive$1.applyOrElse(TcpPipelineHandler.scala:151)
at akka.io.PipelineStage$$anon$7$$anon$8$$anonfun$13.apply(Pipelines.scala:678)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:498)
at akka.actor.ActorCell.invoke(ActorCell.scala:456)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237)
at akka.dispatch.Mailbox.run(Mailbox.scala:219)
at akka.io.PipelineFactory$$anon$6$$anonfun$11.apply(Pipelines.scala:323)
at scala.util.Try$.apply(Try.scala:161)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:385)
at akka.io.PipelineFactory$$anon$6.injectCommand(Pipelines.scala:323)
at akka.io.TcpPipelineHandler$$anonfun$receive$1.applyOrElse(TcpPipelineHandler.scala:151)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:498)
at akka.actor.ActorCell.invoke(ActorCell.scala:456)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:237)
at akka.dispatch.Mailbox.run(Mailbox.scala:219)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:385)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.ClassNotFoundException: net.sandrogrzicic.scalabuff.Parser
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
… 45 more
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.lang.ClassNotFoundException: net.sandrogrzicic.scalabuff.Parser
at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
at java.lang.ClassLoader.loadClass(ClassLoader.java:423)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
at java.lang.ClassLoader.loadClass(ClassLoader.java:356)
… 45 more
Java Result: -1
BUILD SUCCESSFUL (total time: 1 second)
And I get this message in command prompt where Event Store is “up and going” when I´m trying to use the ReadEventExample.java code.
Every time I run the ReadEventExample.java code, I get this message in the command prompt:
[03720,23,14:39:12.344] External TCP connection accepted: [Normal, 127.0.0.1:790
3, L127.0.0.1:1113, {2cfe2651-0e1e-4fd7-82df-a7ca18727e73}].
[03720,23,14:39:12.689] [14:39:12.677: N127.0.0.1:7903, L127.0.0.1:1113, {2cfe26
51-0e1e-4fd7-82df-a7ca18727e73}]:
Received bytes: 0, Sent bytes: 0
Send calls: 0, callbacks: 0
Receive calls: 1, callbacks: 1
Close reason: [ConnectionReset] Socket receive error
[03720,23,14:39:12.704] Connection ‘external-normal’ [127.0.0.1:7903, {2cfe2651-
0e1e-4fd7-82df-a7ca18727e73}] closed: ConnectionReset.
It looks like that the akka-librarys don´t find the Parser-class:
Caused by: java.lang.ClassNotFoundException: net.sandrogrzicic.scalabuff.Parser
Could you please explicitly add this dependency on classpath: “net.sandrogrzicic” % “scalabuff-runtime_2.10” % “1.3.6”, and try ?
What do you mean? How do i add that dependecny on classpath?
java -classpath whatever.jar
or
http://docs.oracle.com/javase/tutorial/essential/environment/paths.html
Your environment might be slightly different but nearly every one I have seen works this way.
Greg
are you using Maven or any other build tool for your project?
I have tried to add this text: “net.sandrogrzicic” % “scalabuff-runtime_2.10” % “1.3.6”, in PATH in environment variables on my computer, but it didn´t work.
I don´t know. I just run the java-code from NetBeans 7.2.
Ok so jvm client has a lot of dependencies, for instance: akka, protobuf, etc…
You need to use some tool that will get all of those dependencies from internet and put on classpath of your applications.
If you are a Java developer, you should try to take a look on https://maven.apache.org/