apache / beam

Apache Beam is a unified programming model for Batch and Streaming data processing.
https://beam.apache.org/
Apache License 2.0
7.89k stars 4.27k forks source link

Read RabbitMQ messages with headers containing nested objects #33072

Open jonomorris opened 2 weeks ago

jonomorris commented 2 weeks ago

Fixes #32885

Since RabbitMQ message headers can contain Lists of Objects that consist of further Lists and/or Maps of Objects, we should recursively process each header until we reach a Serializable Object or a LongString.


Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily:

See the Contributor Guide for more tips on how to make review process smoother.

To check the build health, please visit https://github.com/apache/beam/blob/master/.test-infra/BUILD_STATUS.md

GitHub Actions Tests Status (on master branch)

Build python source distribution and wheels Python tests Java tests Go tests

See CI.md for more information about GitHub Actions CI or the workflows README to see a list of phrases to trigger workflows.

github-actions[bot] commented 2 weeks ago

Checks are failing. Will not request review until checks are succeeding. If you'd like to override that behavior, comment assign set of reviewers

github-actions[bot] commented 2 weeks ago

Assigning reviewers. If you would like to opt out of this review, comment assign to next reviewer:

R: @robertwb for label java. R: @chamikaramj for label io.

Available commands:

The PR bot will only process comments in the main thread (not review comments).

jonomorris commented 2 weeks ago

R: @robertwb

github-actions[bot] commented 2 weeks ago

Stopping reviewer notifications for this pull request: review requested by someone other than the bot, ceding control. If you'd like to restart, comment assign set of reviewers

jonomorris commented 2 weeks ago

assign set of reviewers

github-actions[bot] commented 2 weeks ago

Assigning reviewers. If you would like to opt out of this review, comment assign to next reviewer:

R: @damondouglas for label java. R: @damondouglas for label io.

Available commands:

The PR bot will only process comments in the main thread (not review comments).

github-actions[bot] commented 1 week ago

Reminder, please take a look at this pr: @damondouglas @damondouglas

github-actions[bot] commented 6 days ago

Assigning new set of reviewers because Pr has gone too long without review. If you would like to opt out of this review, comment assign to next reviewer:

R: @robertwb for label java. R: @Abacn for label io.

Available commands: