[IGNITE-534] Implement IgniteJmsStreamer to stream data from a JMS broker like ActiveMQ

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: ignite-1.4
• Component/s: streaming
• Flags: Patch
• Assignee: Valentin Kulichenko
• Reporter: Dmitriy Setrakyan
• Created: 20/Mar/15 15:54
• Updated: 20/Oct/15 16:00
• Resolved: 14/Aug/15 23:14

Description

We have IgniteDataStreamer which is used to load data into Ignite under high load. It was previously named IgniteDataLoader, see ticket IGNITE-394.

We should create IgniteJmsStreamer which will consume messages from a given queue or topic of a JMS broker and stream them into Ignite caches.

Even though we'll use AMQ for testing, this streamer should be implementation-agnostic and only use JMS constructs where possible.

See Apache ActiveMQ for more information.

More details to follow, but to the least we should be able to:

• Convert a JMS message to Ignite data using an optional pluggable converter. If not provided, we should have some default mechanism.
• Specify the cache name for the Ignite cache to load data into.
• Specify other flags available on IgniteDataStreamer class.