簡單消息隊列系統 ElasticMQ 0.3 發布,新 API,新內存存儲

fmms 14年前發布 | 8K 次閱讀 ElasticMQ

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

 本文由用戶 fmms 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!