andyjk15/db-gateway
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[06.10.20] Moved setting of correlationID to before first logging as it was generating a random ID on receiving a message

Browse Source
This commit is contained in:
andyjk15 2020-10-06 19:29:16 +01:00
parent a396b0f002
commit 81b988e7b8
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/cryptosky/me/consumers/PriceConsumer.java
View File

@ -58,10 +58,11 @@ public class PriceConsumer {
String correlationId = getCorrelationId(message); String correlationId = getCorrelationId(message);
String syncId = UUID.randomUUID().toString(); String syncId = UUID.randomUUID().toString();
setCorrelationId(correlationId);
logger.info("Received Message: " + message.getBody(String.class)); logger.info("Received Message: " + message.getBody(String.class));
try { try {
setCorrelationId(correlationId);
if (message.getBody(String.class) == null | message.getBody(String.class).equals("")) { if (message.getBody(String.class) == null | message.getBody(String.class).equals("")) {
throw new NoBodyOrStringException(); throw new NoBodyOrStringException();