ElasticMQ 0.3 发布,新 API,新内存存储

红薯
 红薯
发布于 2012年02月07日
收藏 1

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

该版本包含两个主要改进:

1. 基于内存的消息存储,显著提升性能

使用方法:

  val node = NodeBuilder.withInMemoryStorage().build()
  val server = SQSRestServerFactory.start(node.nativeClient,
    8888, "http://localhost:8888")

2. 主要 API 进行重写,更有面向对象的感觉:

  val node = NodeBuilder.withInMemoryStorage().build()
  val client = node.nativeClient
  val queue = client.createOrLookupQueue("queue1");
  queue.sendMessage("msg1")
  queue.sendMessage(MessageBuilder("msg2").withNextDelivery(tomorrow))
  queue.receiveMessage().map(message => {
    println(message.content)
    message.delete()
  })

详情请看 Client, Queue, QueueOperations, Message and MessageOperations

本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处,尊重他人劳动共创开源社区。
转载请注明:文章转载自 OSCHINA 社区 [http://www.oschina.net]
本文标题:ElasticMQ 0.3 发布,新 API,新内存存储
加载中
返回顶部
顶部