RabbitMqIO uses a deprecated API
Open
bug
io
java
P3
rabbitmq
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
The RabbitMqIo class reader (UnboundedRabbitMqReader) uses the QueueingConsumer, which is denoted as deprecated on RabbitMq side. RabbitMqIo should replace this consumer with the DefaultConsumer provided by RabbitMq.
Imported from Jira [BEAM-7434](https://issues.apache.org/jira/browse/BEAM-7434). Original Jira may contain additional context.
Reported by: riduidel.
Contributor guide
Assessment
This issue has not been assessed yet.