Skip to content

Commit

Permalink
Fixed resource usage and added stack trace print
Browse files Browse the repository at this point in the history
  • Loading branch information
dylan-mulligan committed Nov 24, 2023
1 parent 40bd91d commit af7239a
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -88,8 +88,9 @@ public void run(){
}

logger.info("Waiting for jobs from Crawler...");
try(Connection connection = factory.newConnection();
Channel channel = connection.createChannel()){
try {
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(inputQueue, true, false, false, null);
channel.queueDeclare(outputQueue, true, false, false, null);

Expand Down Expand Up @@ -118,6 +119,7 @@ public void run(){
logger.error("Error occurred while sending the Reconciler message to RabbitMQ: {}", e.getMessage());
} catch (IOException e) {
logger.error(e.getMessage());
e.printStackTrace();
}
}

Expand Down

0 comments on commit af7239a

Please sign in to comment.