This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1ddaa3d Merge pull request #9800: [BEAM-8403] Guard request id generation to prevent concurrent worker access add 6b18af9 [BEAM-8390] usable useCorrelationId with RabbitMq add 58ad984 Merge pull request #9782: [BEAM-8390] Allow specifying useCorrelationId for RabbitMqIO.Read No new revisions were added by this update. Summary of changes: .../java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIO.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+)