You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by József Márton Jung <j....@levi9.com> on 2015/08/28 17:11:34 UTC
Review Request 37890: SAMZA-757 Integrate Samza with RabbitMQ

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/37890/
-----------------------------------------------------------

Review request for samza.


Repository: samza


Description
-------

RabbitMQ integration, initial version. Supports consuming and producing.

I created a sample application which uses RabbitMQ. Uploaded it to and it can be found here: https://github.com/elkware/samza-rabbitmq


Diffs
-----

  build.gradle 3a7fabc 
  gradle/dependency-versions.gradle 36d564b 
  samza-rabbitmq/src/main/java/org/apache/samza/config/RabbitMQConfig.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/RabbitMQAdmin.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/RabbitMQChannel.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/RabbitMQConsumer.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/RabbitMQConsumerMetrics.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/RabbitMQProducer.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/RabbitMQProducerMetrics.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/RabbitMQSystemFactory.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/connection/DefaultRabbitMQConnectionFactory.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/system/rabbitmq/connection/RabbitMQConnectionFactory.java PRE-CREATION 
  samza-rabbitmq/src/main/java/org/apache/samza/util/RabbitMQUtils.java PRE-CREATION 
  samza-rabbitmq/src/test/java/org/apache/samza/helper/RabbitMQConfigHelper.java PRE-CREATION 
  samza-rabbitmq/src/test/java/org/apache/samza/system/rabbitmq/RabbitMQConsumerTest.java PRE-CREATION 
  samza-rabbitmq/src/test/java/org/apache/samza/system/rabbitmq/RabbitMQProducerTest.java PRE-CREATION 
  samza-rabbitmq/src/test/java/org/apache/samza/system/rabbitmq/connection/DefaultRabbitMQConnectionFactoryTest.java PRE-CREATION 
  samza-rabbitmq/src/test/java/org/apache/samza/util/RabbitMQUtilsTest.java PRE-CREATION 
  settings.gradle 4c1aa10 

Diff: https://reviews.apache.org/r/37890/diff/


Testing
-------

The functionality is covered with unit tests.


Thanks,

József Márton Jung