This is an automated email from the ASF dual-hosted git repository.
jbonofre pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from d7b2c0e Merge pull request #9964 from jklukas/csvsink-fix
add 90abf5d [BEAM-8513] Allow reads from exchange-bound queue without
declaring the exchange (#9937)
No new revisions were added by this update.
Summary of changes:
sdks/java/io/rabbitmq/build.gradle | 5 +-
.../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java | 146 +++++++---
.../beam/sdk/io/rabbitmq/ExchangeTestPlan.java | 102 +++++++
.../beam/sdk/io/rabbitmq/RabbitMqIOTest.java | 301 ++++++++++++++++-----
.../beam/sdk/io/rabbitmq/RabbitMqTestUtils.java | 90 ++++++
.../sdk/io/rabbitmq/rabbitmq-io-test-config.json | 30 ++
6 files changed, 570 insertions(+), 104 deletions(-)
create mode 100644
sdks/java/io/rabbitmq/src/test/java/org/apache/beam/sdk/io/rabbitmq/ExchangeTestPlan.java
create mode 100644
sdks/java/io/rabbitmq/src/test/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqTestUtils.java
create mode 100644
sdks/java/io/rabbitmq/src/test/resources/org/apache/beam/sdk/io/rabbitmq/rabbitmq-io-test-config.json
