Skip to content
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.

Sign up for GitHub

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

Fix/failed to get witness xml #220

Open
wants to merge 8 commits into
base: master
Choose a base branch
from
Open

Fix/failed to get witness xml #220

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
3c9bfad
add log
jianmingtu Mar 7, 2024
b5fc880
add log
jianmingtu Mar 7, 2024
74f9e2e
add log
jianmingtu Mar 7, 2024
e14dbb1
add log
jianmingtu Mar 7, 2024
3222fd7
add log
jianmingtu Mar 7, 2024
20b32e7
add logs
jianmingtu Mar 11, 2024
8a31db9
add logs
jianmingtu Mar 11, 2024
684db3a
add logs
jianmingtu Mar 11, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 4 additions & 1 deletion .../java/ca/bc/gov/open/jrccaccess/autoconfigure/plugins/rabbitmq/RabbitMqDocumentInput.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,8 @@
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;

import java.text.MessageFormat;

/**
* The RabbitMqDocumentInput handles document from the rabbitMq message listener
*
Expand Down Expand Up @@ -60,7 +62,8 @@ public void receiveMessage(DocumentReadyMessage documentReadyMessage) throws Doc
if (logger.isDebugEnabled()) {
logger.debug(content);
}



this.documentReadyHandler.handle(content, documentReadyMessage.getTransactionInfo());

logger.debug("attempting to delete the document from redis storage");
Expand Down
3 changes: 3 additions & 0 deletions ...java/ca/bc/gov/open/jrccaccess/autoconfigure/plugins/rabbitmq/RabbitMqDocumentOutput.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,8 @@
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Service;

import java.text.MessageFormat;

/**
* The rabbitMqDocumentOutput provides service to send document ready message
* to the desired Queue.
Expand Down Expand Up @@ -54,6 +56,7 @@ public void send(String content, TransactionInfo transactionInfo) throws Documen
DocumentReadyMessage documentReadyMessage = new DocumentReadyMessage(transactionInfo, documentInfo, documentStorageProperties);

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

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

Expand Down
Loading