[SAMZA-587] Create SystemConsumer and SystemProducer for ActiveMQ

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Labels: gsoc2015 java
• Assignee: Unassigned
• Reporter: Yan Fang
• Created: 06/Mar/15 00:27
• Updated: 09/Dec/15 17:53

Description

ActiveMQ 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 )
3. it is written in Java. Thought previous implementation is using Scala (Kafka Implementation and FileSystem Implementation), 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.

Issue Links

• relates to: SAMZA-757 Create SystemConsumer and SystemProducer for RabbitMQ