简单的Java AMQP服务器

2019-10-24 04:13:27 阅读：206 来源： 互联网

是否有任何用Java编写的简单AMQP服务器/经纪人实现？

我需要将其用于本地集成测试.我想从ant / maven启动它,并且不需要任何功能,例如集群,持久性,性能等.只是一个类似于RabbitMQ的模拟实例,无需安装(仅作为对maven pom的依赖)和配置.

解决方法:

我会说编写集成测试/端到端测试/自动用户接受测试来测试整个应用程序(包括在MQ中完成的所有操作)是完全合法的.您应该明智地选择能够触发类似这样的测试用例,因为它会大大降低测试的反馈循环.

有org.apache.qpid,您可以简单地将其作为mvn / gradle (mvn central)依赖项包含在您的应用程序中(gradle示例)：

testCompile 'org.apache.qpid:qpid-broker:6.0.1'

然后添加一个包含ExternalResource的规则,该规则在您的测试之前启动代理,这有点像此相当简单的设置：

@Rule
private static final ExternalResource embeddedAMQPBroker = new ExternalResource() {
    Broker broker;

    @Override
    protected void before() throws Throwable {
        BrokerOptions brokerOptions = new BrokerOptions();
        brokerOptions.setConfigProperty("qpid.amqp_port", "55672");
        broker = new Broker();
        broker.startup(brokerOptions);
    }

    @Override
    protected void after() {
        broker.shutdown();
    }
};

未经测试,因为对我来说这是行不通的,因为我的所有应用程序都包含Jetty 9,并且QPID(仍然)需要Jetty <9.

标签：unit-testing,amqp,java
来源： https://codeday.me/bug/20191024/1917996.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

简单的Java AMQP服务器