diff --git a/src/main/java/cryptosky/me/consumers/PriceConsumer.java b/src/main/java/cryptosky/me/consumers/PriceConsumer.java
index 0e355fc..0ebb28a 100644
--- a/src/main/java/cryptosky/me/consumers/PriceConsumer.java
+++ b/src/main/java/cryptosky/me/consumers/PriceConsumer.java
@@ -24,6 +24,7 @@ import static cryptosky.me.ArtemisSyncMessaging.*;
 
 import static cryptosky.me.helpers.Utils.getCorrelationId;
 import static cryptosky.me.logging.CorrelationInfo.setCorrelationId;
+import static cryptosky.me.logging.CorrelationInfo.setSyncId;
 import static java.lang.String.format;
 
 @Component
@@ -59,6 +60,7 @@ public class PriceConsumer {
 		String syncId = UUID.randomUUID().toString();
 
 		setCorrelationId(correlationId);
+		setSyncId("");
 
 		logger.info("Received Message: " + message.getBody(String.class));