You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Yan Fang (JIRA)" <ji...@apache.org> on 2015/03/06 01:28:38 UTC

[jira] [Created] (SAMZA-587) Create SystemConsumer and SystemProducer for ActiveMQ

Yan Fang created SAMZA-587:
------------------------------

             Summary: Create SystemConsumer and SystemProducer for ActiveMQ
                 Key: SAMZA-587
                 URL: https://issues.apache.org/jira/browse/SAMZA-587
             Project: Samza
          Issue Type: Improvement
            Reporter: Yan Fang


[ActiveMQ|http://activemq.apache.org/] is a popular messaging queue. It will be great for Samza to be able to read from and write to it. The basic idea is:
1. it will be separated into its own package
2. it implements SystemAdmin, SystemConsumer, SystemProducer. ( check the org.apache.samza.system package in [javadoc|http://samza.apache.org/learn/documentation/0.8/api/javadocs/] )
3. it is written in Java. Thought previous implementation is using Scala ([Kafka Implementation|https://github.com/apache/samza/tree/master/samza-kafka/src/main/scala/org/apache/samza/system/kafka] and [FileSystem Implementation|https://github.com/apache/samza/tree/master/samza-core/src/main/scala/org/apache/samza/system/filereader]), we are moving from Scala to Java. All scala APIs are Java APIs. 
4. two systems mentioned in (3) could be used as a reference.

Also see [comment|https://issues.apache.org/jira/browse/SAMZA-261?focusedCommentId=14349570&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-14349570].




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)