ElasticMQ简单消息队列系统

联合创作 · 2023-10-01 03:21

ElasticMQ 是一个使用 Scala 编写的简单消息队列系统。当前使用嵌入式数据库 H2 来存储消息。ElasticMQ 实现了 SQS REST 接口的子集,提供一个 SQS 的可选方案。

ElasticMQ 使用 Squeryl 来访问数据库。

示例代码:

// First we need to create a Node
val node = NodeBuilder.createNode
// Then we can expose the native client using the SQS REST interface
val server = SQSRestServerFactory.start(node.nativeClient, 8888, "http://localhost:8888")
// ... use ...
// Finally we need to stop the server and the node
server.stop()
node.shutdown()
浏览 7
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报