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();