文件名称：storm-rabbitmq:与Storm中的RabbitMQ进行交互的工具库
文件大小：33KB
文件格式：ZIP
更新时间：2024-05-18 08:55:21
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)