----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/41144/ -----------------------------------------------------------
Review request for samza. Repository: samza Description ------- Integration with ActiveMQ. Supports consuming from and producing messages to ActiveMQ queues. Diffs ----- build.gradle 0541def1b3ee15dceeb354840815ac1333340515 gradle/dependency-versions.gradle 52e25aa53a1edc85d478b48898621b26508ad4bb samza-activemq/src/main/java/org/apache/samza/config/ActiveMQConfig.java PRE-CREATION samza-activemq/src/main/java/org/apache/samza/system/activemq/ActiveMQAdmin.java PRE-CREATION samza-activemq/src/main/java/org/apache/samza/system/activemq/ActiveMQConsumer.java PRE-CREATION samza-activemq/src/main/java/org/apache/samza/system/activemq/ActiveMQProducer.java PRE-CREATION samza-activemq/src/main/java/org/apache/samza/system/activemq/ActiveMQProducerMetrics.java PRE-CREATION samza-activemq/src/main/java/org/apache/samza/system/activemq/ActiveMQSystemFactory.java PRE-CREATION samza-activemq/src/test/java/org/apache/samza/system/activemq/ActiveMQConsumerTest.java PRE-CREATION samza-activemq/src/test/java/org/apache/samza/system/activemq/ActiveMQProducerTest.java PRE-CREATION samza-activemq/src/test/java/org/apache/samza/system/activemq/ActiveMQTestHelper.java PRE-CREATION settings.gradle 4c1aa107a11d413777e69bc4e48847b811aff7d2 Diff: https://reviews.apache.org/r/41144/diff/ Testing ------- Unit tests for producer and consumer. Thanks, Ben Damer
