----------------------------------------------------------- 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
