Merge branch 'ishark-rabbitMQ' into v3.1.0
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/0b3bb88d Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/0b3bb88d Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/0b3bb88d Branch: refs/heads/master Commit: 0b3bb88d8ebd2e52d483f77f7951eb56767f32df Parents: 8e94665 4dc4788 Author: Chandni Singh <[email protected]> Authored: Wed Aug 12 21:08:44 2015 -0700 Committer: Chandni Singh <[email protected]> Committed: Wed Aug 12 21:08:44 2015 -0700 ---------------------------------------------------------------------- .../rabbitmq/AbstractRabbitMQInputOperator.java | 142 +++++++++++++++++-- .../AbstractRabbitMQOutputOperator.java | 65 ++++++++- ...bstractSinglePortRabbitMQOutputOperator.java | 5 +- .../rabbitmq/RabbitMQInputOperatorTest.java | 86 ++++++++--- .../rabbitmq/RabbitMQOutputOperatorTest.java | 28 ++-- 5 files changed, 278 insertions(+), 48 deletions(-) ----------------------------------------------------------------------
