diff --git a/src/main/java/cryptosky/me/consumers/PriceConsumer.java b/src/main/java/cryptosky/me/consumers/PriceConsumer.java index 3d28aa8..205e97e 100644 --- a/src/main/java/cryptosky/me/consumers/PriceConsumer.java +++ b/src/main/java/cryptosky/me/consumers/PriceConsumer.java @@ -78,7 +78,7 @@ public class PriceConsumer { JsonNode messageJson = objectMapper.readTree(message.getText()); cryptoPriceModel = objectMapper.readValue(messageJson.traverse(), CryptoPriceModel.class); - logger.info("Message with syncId of [{}] is for customer [{}]", syncId, cryptoPriceModel); + logger.info("Message with syncId of [{}] is for [{}]", syncId, cryptoPriceModel); priceService.createRecord(cryptoPriceModel, correlationId, message); diff --git a/src/main/java/cryptosky/me/consumers/TweetConsumer.java b/src/main/java/cryptosky/me/consumers/TweetConsumer.java index 5fc640e..8abc454 100644 --- a/src/main/java/cryptosky/me/consumers/TweetConsumer.java +++ b/src/main/java/cryptosky/me/consumers/TweetConsumer.java @@ -77,7 +77,7 @@ public class TweetConsumer { JsonNode messageJson = objectMapper.readTree(message.getText()); sentimentModel = objectMapper.readValue(messageJson.traverse(), SentimentModel.class); - logger.info("Message with syncId of [{}] is for customer [{}]", syncId, sentimentModel); + logger.info("Message with syncId of [{}] is for [{}]", syncId, sentimentModel); sentimentService.createRecord(sentimentModel, correlationId, message); diff --git a/src/main/java/cryptosky/me/sentiment/models/entities/SentimentModel.java b/src/main/java/cryptosky/me/sentiment/models/entities/SentimentModel.java index 96423fd..7f53de7 100644 --- a/src/main/java/cryptosky/me/sentiment/models/entities/SentimentModel.java +++ b/src/main/java/cryptosky/me/sentiment/models/entities/SentimentModel.java @@ -14,7 +14,6 @@ public class SentimentModel { @Id @Column(name = "ID", nullable = false) - @GeneratedValue(strategy = GenerationType.IDENTITY) private int id; @Column(name = "timestamp",nullable = false)