ElasticMQ 0.2 – 支持延迟队列和消息

红薯
 红薯
发布于 2012年01月15日
收藏 7

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

ElasticMQ 0.2 最值得关注的就是支持延迟队列和消息,另外实现了 Amazon SQS 接口。

// First we need to create a Node
val node = NodeBuilder.withInMemoryStorage().build()
// Then we can expose the native client using the SQS REST interface
val server = SQSRestServerFactory.start(node.nativeClient, 8888,
      "http://localhost:8888")

// Now we need to create the sqs client
client = new AmazonSQSClient(new BasicAWSCredentials("x", "x"))
client.setEndpoint("http://localhost:8888")

// Using the client is quite straightforward
val queueUrl = client.createQueue(new CreateQueueRequest("queue1"))
      .getQueueUrl
client.sendMessage(new SendMessageRequest(queueUrl, "message1"))

client.shutdown()

// Finally we need to stop the server and the node
server.stop()
node.shutdown()
本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处,尊重他人劳动共创开源社区。
转载请注明:文章转载自 OSCHINA 社区 [http://www.oschina.net]
本文标题:ElasticMQ 0.2 – 支持延迟队列和消息
加载中
返回顶部
顶部