簡單消息隊列系統 ElasticMQ 0.3 發布,新 API,新內存存儲
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 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!