ElasticMQ 0.2 – 支持延迟队列和消息
程序员文章站
2022-04-17 15:11:00
...
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()
本文来自:开源中国社区