简单消息队列系统 ElasticMQ 0.3 发布,新 API,新内存存储

fmms 13年前
     <p>ElasticMQ 0.3 发布了,ElasticMQ 是一个使用 Scala 编写的简单消息队列系统。当前使用嵌入式数据库 H2 来存储消息。ElasticMQ 实现了 SQS REST 接口的子集,提供一个 SQS 的可选方案。</p>    <p>该版本包含两个主要改进:</p>    <p>1. 基于内存的消息存储,显著提升性能</p>    <p>使用方法:</p>    <pre class="brush: scala; title: ; notranslate">  val node = NodeBuilder.withInMemoryStorage().build()    val server = SQSRestServerFactory.start(node.nativeClient,      8888, "http://localhost:8888")</pre>    <p>2. 主要 API 进行重写,更有面向对象的感觉:</p>    <pre class="brush: scala; title: ; notranslate">  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()    })</pre>    <p>详情请看 <a href="/misc/goto?guid=4958328444072585350">Client</a>, <a href="/misc/goto?guid=4958328444881137307">Queue</a>, <a href="/misc/goto?guid=4958328445672976226">QueueOperations</a>, <a href="/misc/goto?guid=4958328446476249468">Message</a> and <a href="/misc/goto?guid=4958328447271241285">MessageOperations</a></p>