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

[15.10.20] Logging changes

Browse Source
This commit is contained in:
andyjk15 2020-10-15 20:33:57 +01:00
parent ddb5012b95
commit 1b1bde8c76
3 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -78,7 +78,7 @@ public class PriceConsumer {
JsonNode messageJson = objectMapper.readTree(message.getText()); JsonNode messageJson = objectMapper.readTree(message.getText());
cryptoPriceModel = objectMapper.readValue(messageJson.traverse(), CryptoPriceModel.class); 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); priceService.createRecord(cryptoPriceModel, correlationId, message);

2
src/main/java/cryptosky/me/consumers/TweetConsumer.java
View File

@ -77,7 +77,7 @@ public class TweetConsumer {
JsonNode messageJson = objectMapper.readTree(message.getText()); JsonNode messageJson = objectMapper.readTree(message.getText());
sentimentModel = objectMapper.readValue(messageJson.traverse(), SentimentModel.class); 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); sentimentService.createRecord(sentimentModel, correlationId, message);

1
src/main/java/cryptosky/me/sentiment/models/entities/SentimentModel.java
View File

@ -14,7 +14,6 @@ public class SentimentModel {
@Id @Id
@Column(name = "ID", nullable = false) @Column(name = "ID", nullable = false)
@GeneratedValue(strategy = GenerationType.IDENTITY)
private int id; private int id;
@Column(name = "timestamp",nullable = false) @Column(name = "timestamp",nullable = false)