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 2ff462d Merge pull request #9752: [BEAM-8183] restructure Flink
portable jars to support multiple pipelines
new 7f66522 fix for message being not serializable due to LongString in
headers
new 05db193 [BEAM-7414] applying Beam project style guides (or trying so)
new 3c845cb [BEAM-7414] Fixing test failures : seems like generated test
messages have no header values, which made LongString-elimination code failing
new 36d289b Seems like i changed that line by error. Rolling that back.
new 51fabee That code was useless Indeed, if there is an IOException when
trying to ack the message, there most probably be one when trying to nack the
message.
new 5252a20 According to jbonofre, the transformation of deliverable into
serializable objects lies in RabbitMqMessage And i agree, it's way better.
new d8d8761 fixed one last formatting point
new 5a851b7 Merge pull request #8677 from
Riduidel/fix/rabbitmq-message-not-serializable
The 23451 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java | 4 +-
.../beam/sdk/io/rabbitmq/RabbitMqMessage.java | 66 ++++++++++++++++++++++
2 files changed, 68 insertions(+), 2 deletions(-)
