[FLINK-22698][connectors/rabbitmq] Add deliveryTimeout to RabbitMQ source

This change enables setting the message delivery timeout in the RabbitMQ queueing consumer, allowing to properly stop the job in cases when no new message is available on the queue.

Changes:
- Add the ability to setDeliveryTimeout on the RMQConnectionConfig and its builder
- Change default message delivery timeout in the RMQSource to 30 seconds (previously there was no timeout)
- Extend RabbitMQ source unit tests
6 files changed
tree: afd15934213ee425a408f663783bb60d649efd3e
  1. .github/
  2. .idea/
  3. docs/
  4. flink-connector-rabbitmq/
  5. tools/
  6. .asf.yaml
  7. .gitignore
  8. LICENSE
  9. NOTICE
  10. README.md
README.md

flink-connector-rabbitmq