【文件属性】：
文件名称：storm-rabbitmq:与Storm中的RabbitMQ进行交互的工具库
文件大小：33KB
文件格式：ZIP
更新时间：2021-04-28 15:08:41
Java
风暴兔
风暴的RabbitMQ是在与集成所采用的工具库从。 该库专门用于RabbitMQ，可能无法与其他AMQP代理一起使用，因为该库将使用RabbitMQ特定于AMQP的扩展。
许可证：MIT许可证
先决条件
您将需要实现backtype.storm.spout.Scheme来反序列化RabbitMQ消息。
RabbitMQ喷口
该喷口将使用YourCustomMessageScheme对输入的消息进行反序列YourCustomMessageScheme ，并在锚定流YourCustomMessageScheme其发出。
Scheme scheme = new YourCustomMessageScheme ();
IRichSpout spout = new RabbitMQSpout (scheme);
配置与RabbitMQ的连接。 如果打开requeueOnFail则如果
【文件预览】：
storm-rabbitmq-master
----RELEASE.md(1KB)
----src()
--------main()
----.travis.yml(61B)
----LICENSE(1KB)
----README.md(12KB)
----pom.xml(5KB)
----.gitignore(15B)