esj:用于 EventStore 的 Java 客户端 (http-源码
esj
EventStore 的 Java 客户端 ( )
关于
事件存储 Java 客户端。 旨在帮助 Java 程序轻松与 Event Store 数据库进行通信。
功能
Java客户端功能：
将事件附加到流
从流中读取
订阅流
删除流
从流中读取事件
代码示例
附加到流示例：
import lt.emasina.esj.EventStore;
import lt.emasina.esj.model.Message;
...
EventStore es = new EventStore(InetAddress.getByName(HOSTNAME), PORTNUMBER);
...
es.appendToStream(STREAM_NAME, new ResponseReceiver() {
@Override
public void onResponseReturn(Me
文件下载
资源详情
[{"title":"（ 71 个子文件 110KB ） esj:用于 EventStore 的 Java 客户端 (http-源码","children":[{"title":"esj-master","children":[{"title":"client","children":[{"title":"pom.xml <span style='color:#111;'> 4.36KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"tools","children":[{"title":"Message.proto <span style='color:#111;'> 5.36KB </span>","children":null,"spread":false},{"title":"rebuild.sh <span style='color:#111;'> 652B </span>","children":null,"spread":false},{"title":"Message.proto.bak <span style='color:#111;'> 5.36KB </span>","children":null,"spread":false}],"spread":true},{"title":"test","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 717B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"lt","children":[{"title":"emasina","children":[{"title":"esj","children":[{"title":"EventStoreIT.java <span style='color:#111;'> 9.10KB </span>","children":null,"spread":false},{"title":"Writer.java <span style='color:#111;'> 3.19KB </span>","children":null,"spread":false},{"title":"EventSendIT.java <span style='color:#111;'> 4.00KB </span>","children":null,"spread":false},{"title":"TestResponseReceiver.java <span style='color:#111;'> 1.32KB </span>","children":null,"spread":false},{"title":"UtilityTest.java <span style='color:#111;'> 762B </span>","children":null,"spread":false},{"title":"SemaphoreTest.java <span style='color:#111;'> 1.09KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":".gitkeep <span style='color:#111;'> 0B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"lt","children":[{"title":"emasina","children":[{"title":"esj","children":[{"title":"Settings.java <span style='color:#111;'> 442B </span>","children":null,"spread":false},{"title":"operation","children":[{"title":"HeartBeatResponseOperation.java <span style='color:#111;'> 658B </span>","children":null,"spread":false},{"title":"DropSubscriptionOperation.java <span style='color:#111;'> 640B </span>","children":null,"spread":false},{"title":"AppendToStreamOperation.java <span style='color:#111;'> 621B </span>","children":null,"spread":false},{"title":"SubscribeToStreamOperation.java <span style='color:#111;'> 1.17KB </span>","children":null,"spread":false},{"title":"ReadEventFromStreamOperation.java <span style='color:#111;'> 622B </span>","children":null,"spread":false},{"title":"DeleteStreamOperation.java <span style='color:#111;'> 626B </span>","children":null,"spread":false},{"title":"ReadAllEventsForwardOperation.java <span style='color:#111;'> 690B </span>","children":null,"spread":false},{"title":"HeartBeatOperation.java <span style='color:#111;'> 517B </span>","children":null,"spread":false}],"spread":true},{"title":"ResponseReceiver.java <span style='color:#111;'> 203B </span>","children":null,"spread":false},{"title":"model","children":[{"title":"ResponseOperation.java <span style='color:#111;'> 284B </span>","children":null,"spread":false},{"title":"ExpectedVersion.java <span style='color:#111;'> 682B </span>","children":null,"spread":false},{"title":"ParseException.java <span style='color:#111;'> 318B </span>","children":null,"spread":false},{"title":"Event.java <span style='color:#111;'> 5.38KB </span>","children":null,"spread":false},{"title":"RequestOperation.java <span style='color:#111;'> 1.33KB </span>","children":null,"spread":false},{"title":"RequestResponseOperation.java <span style='color:#111;'> 2.36KB </span>","children":null,"spread":false},{"title":"UserCredentials.java <span style='color:#111;'> 1.57KB </span>","children":null,"spread":false},{"title":"RequestMultipleResponsesOperation.java <span style='color:#111;'> 3.43KB </span>","children":null,"spread":false},{"title":"Message.java <span style='color:#111;'> 3.04KB </span>","children":null,"spread":false},{"title":"converter","children":[{"title":"JsonToByteStringConverter.java <span style='color:#111;'> 713B </span>","children":null,"spread":false},{"title":"ObjectToByteStringConverter.java <span style='color:#111;'> 926B </span>","children":null,"spread":false},{"title":"StringToByteStringConverter.java <span style='color:#111;'> 595B </span>","children":null,"spread":false},{"title":"ByteArrayToByteStringConverter.java <span style='color:#111;'> 965B </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"EventStore.java <span style='color:#111;'> 13.90KB </span>","children":null,"spread":false},{"title":"MultipleResponsesReceiver.java <span style='color:#111;'> 244B </span>","children":null,"spread":false},{"title":"message","children":[{"title":"ExceptionMessage.java <span style='color:#111;'> 912B </span>","children":null,"spread":false},{"title":"HeartBeat.java <span style='color:#111;'> 290B </span>","children":null,"spread":false},{"title":"WriteEvents.java <span style='color:#111;'> 4.47KB </span>","children":null,"spread":false},{"title":"SubscribeToStream.java <span style='color:#111;'> 1.18KB </span>","children":null,"spread":false},{"title":"SubscriptionConfirmation.java <span style='color:#111;'> 1.53KB </span>","children":null,"spread":false},{"title":"HeartBeatResponse.java <span style='color:#111;'> 309B </span>","children":null,"spread":false},{"title":"StreamEventAppeared.java <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false},{"title":"ReadAllEventsForward.java <span style='color:#111;'> 1.60KB </span>","children":null,"spread":false},{"title":"DeleteStreamCompleted.java <span style='color:#111;'> 1.31KB </span>","children":null,"spread":false},{"title":"ReadEventCompleted.java <span style='color:#111;'> 3.10KB </span>","children":null,"spread":false},{"title":"SubscriptionDropped.java <span style='color:#111;'> 1.50KB </span>","children":null,"spread":false},{"title":"DropSubscription.java <span style='color:#111;'> 845B </span>","children":null,"spread":false},{"title":"ReadEvent.java <span style='color:#111;'> 1.33KB </span>","children":null,"spread":false},{"title":"WriteEventsCompleted.java <span style='color:#111;'> 1.56KB </span>","children":null,"spread":false},{"title":"ReadAllEventsForwardCompleted.java <span style='color:#111;'> 2.44KB </span>","children":null,"spread":false},{"title":"DeleteStream.java <span style='color:#111;'> 1.50KB </span>","children":null,"spread":false},{"title":"ClientMessageDtos.java <span style='color:#111;'> 667.57KB </span>","children":null,"spread":false}],"spread":false},{"title":"util","children":[{"title":"Bytes.java <span style='color:#111;'> 3.04KB </span>","children":null,"spread":false},{"title":"Hex.java <span style='color:#111;'> 6.42KB </span>","children":null,"spread":false}],"spread":false},{"title":"tcp","children":[{"title":"TcpSender.java <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false},{"title":"TcpCommand.java <span style='color:#111;'> 2.13KB </span>","children":null,"spread":false},{"title":"TcpPackage.java <span style='color:#111;'> 5.23KB </span>","children":null,"spread":false},{"title":"TcpFramer.java <span style='color:#111;'> 1.11KB </span>","children":null,"spread":false},{"title":"TcpReceiver.java <span style='color:#111;'> 4.09KB </span>","children":null,"spread":false},{"title":"TcpFlag.java <span style='color:#111;'> 699B </span>","children":null,"spread":false},{"title":"TcpSocketManager.java <span style='color:#111;'> 5.79KB </span>","children":null,"spread":false},{"title":"TcpConnection.java <span style='color:#111;'> 1.73KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".gitignore <span style='color:#111;'> 16B </span>","children":null,"spread":false}],"spread":true},{"title":"LICENSE <span style='color:#111;'> 7.45KB </span>","children":null,"spread":false},{"title":"doc","children":[{"title":"UML - message classes.ucls <span style='color:#111;'> 17.92KB </span>","children":null,"spread":false},{"title":"UML - message structure.ucls <span style='color:#111;'> 8.96KB </span>","children":null,"spread":false},{"title":"UML - TCP connection classes.ucls <span style='color:#111;'> 8.43KB </span>","children":null,"spread":false}],"spread":true},{"title":".gitignore <span style='color:#111;'> 15B </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 2.22KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]
评论信息
其他资源
- saber flyback 实例
- 蒙特卡洛模拟光子在组织中的运动 matlab
- MmLoadDriver内存加载驱动.7z
- 疲劳检测程序源码
- 软件工程实验—物流公司管理系统用例图
- 四叉树定义实现C++代码
- MSP-EXP430F5529 LAB CODE里面全是很好的例程，这是我们实验中心的学习例程，很适合430的入门者！
- WPF旅游管理系统（增删改查）实例实用
- 用C#实现图片轮播
- 计算机网络课件（与谢希仁教材第五版配套）
- 编程简介（Java）-跨学科方法Introduction to Programming (in Java) - An Interdisciplinary Approach
- 【MFC】定义XP风格的工具栏.rar
- 管理信息系统自测题（含答案）1.zip
- Web服务
- ActiveBPEL中组合服务自动部署的研究和实现
- 信息系统安全等级保护方案.pptx
- katacoda方案：Katacoda方案-源码
- 4AM1U2P2课件.ppt
- iCAM自动编程系统2018（一代加密狗）
- 基于ASP的网上交易系统论文及毕业设计_开题报告
- ArcMap2SLD_Code_1.3.0
- 文件路径的正则表达式
- Northwind MySql格式
- 最新验证身份证前6为json数据大全
免责申明
【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论 【只为小站】 经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明