-
Notifications
You must be signed in to change notification settings - Fork 5
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
QueueingConsumer class is deprecated and might be replaced #45
Comments
Create a custom class CustomConsumer which extends DefaultConsumer class and override the method handleDelivery to add each delivery to a public class variable LinkedBlockingQueue deliveryQueue. Which will be used to fetch deliveries. |
@sourabhpoddar404 and @altafhusen-mr Please do not simply make the queue attribute |
Sure @MichaelRoeder we'll update it accordingly. |
Description
The RabbitMQ client class QueueingConsumer used in our implementation is marked deprecated in favor of a the DefaultConsumer implementation (see https://github.com/rabbitmq/rabbitmq-java-client/blob/v4.8.0/src/main/java/com/rabbitmq/client/QueueingConsumer.java#L64-L92). It might be necessary to replace the implementation in the future since deprecated classes can be removed from projects.
This mainly affects the classes
The text was updated successfully, but these errors were encountered: