Skip to content

Commit e323f93

Browse files
committed
fixer logger class name
1 parent 13d6df7 commit e323f93

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

maven-miner-parent/maven-miner-aether/src/main/java/fr/inria/diverse/maven/resolver/launcher/ConsumerResolverApp.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ public class ConsumerResolverApp {
5757
/**
5858
* The resolver application logger
5959
*/
60-
private static final Logger LOGGER = LoggerFactory.getLogger(BatchResolverApp.class);
60+
private static final Logger LOGGER = LoggerFactory.getLogger(ConsumerResolverApp.class);
6161

6262
/**
6363
* A multiTask visitor. To add additional visit behaviour/task @see {@link MultiTaskDependencyVisitor}
@@ -203,14 +203,14 @@ public void shutdownCompleted(ShutdownSignalException cause)
203203
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
204204
throws IOException {
205205
try {
206+
channel.basicAck(envelope.getDeliveryTag(), false);
206207
String artifactCoordinate = new String(body, "UTF-8");
207208
DefaultArtifact artifact = new DefaultArtifact(artifactCoordinate);
208209
processor.process(artifact);
209210
} catch (Exception e) {
210211
LOGGER.error("Handle deleviery Error {}", e.getMessage());
211212
} finally {
212-
213-
channel.basicAck(envelope.getDeliveryTag(), false);
213+
//channel.basicAck(envelope.getDeliveryTag(), false);
214214
}
215215
}
216216
});

0 commit comments

Comments
 (0)