From 81b988e7b8a5e4f638db24402fdbed78e152bcb4 Mon Sep 17 00:00:00 2001 From: andyjk15 Date: Tue, 6 Oct 2020 19:29:16 +0100 Subject: [PATCH] [06.10.20] Moved setting of correlationID to before first logging as it was generating a random ID on receiving a message --- src/main/java/cryptosky/me/consumers/PriceConsumer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/cryptosky/me/consumers/PriceConsumer.java b/src/main/java/cryptosky/me/consumers/PriceConsumer.java index b1a9ded..0e355fc 100644 --- a/src/main/java/cryptosky/me/consumers/PriceConsumer.java +++ b/src/main/java/cryptosky/me/consumers/PriceConsumer.java @@ -58,10 +58,11 @@ public class PriceConsumer { String correlationId = getCorrelationId(message); String syncId = UUID.randomUUID().toString(); + setCorrelationId(correlationId); + logger.info("Received Message: " + message.getBody(String.class)); try { - setCorrelationId(correlationId); if (message.getBody(String.class) == null | message.getBody(String.class).equals("")) { throw new NoBodyOrStringException();