[
https://issues.apache.org/jira/browse/SAMZA-587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047211#comment-15047211
]
Yi Pan (Data Infrastructure) commented on SAMZA-587:
----------------------------------------------------
[~bdamer], that's awesome! Please follow the wiki here to create the review
board: https://cwiki.apache.org/confluence/display/SAMZA/Contributor%27s+Corner
And in addition to review board, when you have the patch read, please attach to
this JIRA as well, as Apache needs the attached patch as a proof of granting of
copy-right.
[~renato2099], I remember that you have some implementation of ActiveMQ
Producer/Consumer as well, could you sync up w/ [~bdamer]?
Thanks a lot and this is awesome!
> 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
> Labels: gsoc2015, java
>
> [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)
