Only listing significant user-visible, not internal code cleanups and minor bug fixes.
- Compatibility for Spark version 1.6.1
- Bug fixing
- Distributed RabbitMQ consumer with direct approach
- Parallelize the consumption in one node, to have more than one consumer
- Encapsulated consumer and pool of consumers
- Optimized RabbitMQRDD functions in order to have better performance
- RabbitMQ messages can be typed
- Integration tests added for Scala implementation
- Java examples and refactor rabbitMQUtils
- Compatibility for Spark versions 1.4 and 1.5
- Bug fixing
- First version