ElasticMQ0.2–支持延迟队列和消息

来源：懂视网责编：小采时间：2020-11-09 08:20:37

ElasticMQ0.2–支持延迟队列和消息

ElasticMQ0.2–支持延迟队列和消息:ElasticMQ 是一个使用 Scala 编写的简单消息队列系统。当前使用嵌入式数据库 H2 来存储消息。ElasticMQ 实现了 SQS REST 接口的子集，提供一个 SQS 的可选方案。 ElasticMQ 0.2 最值得关注的就是支持延迟队列和消息，另外实现了 Amazon SQS 接口

推荐度：

点击下载本文 文档为doc格式

导读ElasticMQ0.2–支持延迟队列和消息:ElasticMQ 是一个使用 Scala 编写的简单消息队列系统。当前使用嵌入式数据库 H2 来存储消息。ElasticMQ 实现了 SQS REST 接口的子集，提供一个 SQS 的可选方案。 ElasticMQ 0.2 最值得关注的就是支持延迟队列和消息，另外实现了 Amazon SQS 接口

ElasticMQ 是一个使用 Scala 编写的简单消息队列系统。当前使用嵌入式数据库 H2 来存储消息。ElasticMQ 实现了 SQS REST 接口的子集，提供一个 SQS 的可选方案。 ElasticMQ 0.2 最值得关注的就是支持延迟队列和消息，另外实现了 Amazon SQS 接口。 // First

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()

本文来自：开源中国社区

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。TEL:177 7030 7066 E-MAIL:11247931@qq.com

ElasticMQ0.2–支持延迟队列和消息

推荐度：

点击下载本文 文档为doc格式

标签：消息支持延迟

热门焦点

ElasticMQ0.2–支持延迟队列和消息

ElasticMQ0.2–支持延迟队列和消息

ElasticMQ0.2–支持延迟队列和消息

最新推荐

猜你喜欢

热门推荐