We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 93d911c commit 8f528f8Copy full SHA for 8f528f8
1 file changed
amqp/src/main/java/com/netflix/conductor/contribs/queue/amqp/AMQPObservableQueue.java
@@ -191,7 +191,7 @@ public List<String> ack(List<Message> messages) {
191
final List<String> failedMessages = new ArrayList<>();
192
if (!useExchange) {
193
// only attempt to ack messages when using queues.
194
- // it make no sense to ack over exchange since the message is no longer there.
+ // it makes no sense to ack over exchange since the messages are no longer there.
195
for (final Message message : messages) {
196
try {
197
ackMsg(message);
0 commit comments