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