| commit | 29da14d5bbfa4202e6bd58aba8b1ebcbeac919d6 | [log] [tgz] |
|---|---|---|
| author | gyao <gary@data-artisans.com> | Thu Jun 21 19:24:13 2018 +0200 |
| committer | MartijnVisser <martijn@2symbols.com> | Tue Dec 13 10:40:47 2022 +0100 |
| tree | 98a7b434491b502a9e8fae891f6ff32cb3178e93 | |
| parent | 40410dc505ae092e9f24246a1f0d33ac8ee6b02b [diff] |
[FLINK-8468][RabbitMQ] Improve RabbitMQ connector Remove text from README.md because it is covered by Javadocs. [FLINK-8468][RabbitMQ] Introduce SerializableReturnListener interface. [FLINK-8468][RabbitMQ] Update RMQSinkPublishOptions. Improve Javadocs. Add default implementation for methods computeMandatory and computeImmediate. [FLINK-8468][RabbitMQ] Replace statements with Preconditions.checkState This closes #5410.