You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ec...@apache.org on 2018/10/25 07:56:38 UTC

[beam] 01/01: Merge pull request #1729 from jbonofre/BEAM-1240-RABBITMQIO

This is an automated email from the ASF dual-hosted git repository.

echauchot pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 6c1d92ac9d85ff7bd66ea5c804ad364bb3dbc65b
Merge: 747b4ec 119d0bc
Author: Etienne Chauchot <ec...@apache.org>
AuthorDate: Thu Oct 25 09:56:30 2018 +0200

    Merge pull request #1729 from jbonofre/BEAM-1240-RABBITMQIO
    
    Merge pull request #1729: [BEAM-1240] Create RabbitMqIO

 sdks/java/io/rabbitmq/build.gradle                 |  38 ++
 .../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java    | 641 +++++++++++++++++++++
 .../beam/sdk/io/rabbitmq/RabbitMqMessage.java      | 252 ++++++++
 .../apache/beam/sdk/io/rabbitmq/package-info.java  |  20 +
 .../beam/sdk/io/rabbitmq/RabbitMqIOTest.java       | 315 ++++++++++
 sdks/java/io/rabbitmq/src/test/qpid/etc/passwd     |  19 +
 settings.gradle                                    |   2 +
 7 files changed, 1287 insertions(+)