Skip to content

Commit

Permalink
add logs
Browse files Browse the repository at this point in the history
  • Loading branch information
jianmingtu committed Mar 11, 2024
1 parent 20b32e7 commit 8a31db9
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,8 @@ public void receiveMessage(DocumentReadyMessage documentReadyMessage) throws Doc
logger.debug(content);
}

logger.info(MessageFormat.format("Receiving a transaction with [{0}] on document [{1}] with [key {2}, digest {3} and content {4} ] from RabbitMQ", documentReadyMessage.getTransactionInfo(), documentReadyMessage.getDocumentInfo(), documentReadyMessage.getDocumentStorageProperties().getKey(), documentReadyMessage.getDocumentStorageProperties().getDigest(), content ));

// TODO logger.info(MessageFormat.format("Receiving a transaction with [{0}] on document [{1}] with [key {2}, digest {3} and content {4} ] from RabbitMQ", documentReadyMessage.getTransactionInfo(), documentReadyMessage.getDocumentInfo(), documentReadyMessage.getDocumentStorageProperties().getKey(), documentReadyMessage.getDocumentStorageProperties().getDigest(), content ));
logger.info(MessageFormat.format("Receiving content {0} ] from RabbitMQ", content ));
this.documentReadyHandler.handle(content, documentReadyMessage.getTransactionInfo());

logger.debug("attempting to delete the document from redis storage");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public void send(String content, TransactionInfo transactionInfo) throws Documen

logger.debug("Attempting to publish [{}] ready message to [{}] topic.", documentInfo, RabbitMqParam.DOCUMENT_READY_TOPIC);

logger.info(MessageFormat.format("Publishing a transaction with [{0}] on document [{1}] with [key {2}, digest {3} ] with to RabbitMQ", documentReadyMessage.getTransactionInfo(), documentReadyMessage.getDocumentInfo(), documentReadyMessage.getDocumentStorageProperties().getKey(), documentReadyMessage.getDocumentStorageProperties().getDigest()) );
// TODO logger.info(MessageFormat.format("Publishing a transaction with [{0}] on document [{1}] with [key {2}, digest {3} ] with to RabbitMQ", documentReadyMessage.getTransactionInfo(), documentReadyMessage.getDocumentInfo(), documentReadyMessage.getDocumentStorageProperties().getKey(), documentReadyMessage.getDocumentStorageProperties().getDigest()) );

this.rabbitMqDocumentReadyService.publish(documentReadyMessage);
logger.info("[{}] successfully published to [{}] with [{}] routing key", documentInfo, RabbitMqParam.DOCUMENT_READY_TOPIC, accessProperties.getOutput().getDocumentType());
Expand Down

0 comments on commit 8a31db9

Please sign in to comment.