java - 在 Java 中运行内存中的 elasticMQ

Question

我正在尝试获取一个嵌入式 SQS 模拟，用于对 Java SQS 客户端进行一些独立的本地测试。

ElasticMQ 听起来应该能满足我的要求，但说明似乎假定我使用的是 Java，而我不知道如何从 Java 中启动 ElasticMQ 的其余服务器。

我已经尝试了我认为是 https://github.com/adamw/elasticmq#starting-an-embedded-elasticmq-server-with-an-sqs-interface 提供的代码的 Java 等价物:

RestServer server = new SQSRestServerBuilder().start()

但 SQSRestServerBuilder() 需要一个 Client 参数，我不知道该放什么。

还有其他人让 ElasticMQ 在 Java 中运行在内存中吗？

Answer 1

SQSRestServerBuilder 的最新版本似乎不需要Client 参数。您使用的是旧版本的 ElasticMQ 吗？

参见 https://github.com/adamw/elasticmq/blob/master/rest/rest-sqs/src/main/scala/org/elasticmq/rest/sqs/SQSRestServerBuilder.scala

如果您使用的是旧版本，您可以通过执行以下操作在内存中创建 SQS 服务器:

import org.elasticmq.Node
import org.elasticmq.NodeBuilder
import org.elasticmq.rest.RestServer
import org.elasticmq.rest.sqs.SQSRestServerBuilder
import org.elasticmq.storage.inmemory.InMemoryStorage

...

Node node = NodeBuilder.withStorage(new InMemoryStorage())
RestServer sqsServer = new SQSRestServerBuilder(node.nativeClient()).start()

以上代码是ElasticMQ 0.6.3的具体示例，依赖Scala 2.10。