Rename some classes and records

Author: Ivan Franchin

README.adoc

@@ -68,7 +68,7 @@ Inside the `springboot-kafka-websocket` root folder, run the following `Maven` c
 
 === Build Application's Docker Image
 
-* In a terminal, make sure you are in the `springboot-kafka-websocket` root folder;
+* In a terminal, make sure you are inside the `springboot-kafka-websocket` root folder;
 
 * In order to build the application docker images, run the following script:
 +

bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/PriceEmitter.java renamed to bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/PriceEventEmitter.java

@@ -1,6 +1,6 @@
 package com.ivanfranchin.bitcoinapi.price;
 
-import com.ivanfranchin.bitcoinapi.price.message.PriceMessage;
+import com.ivanfranchin.bitcoinapi.price.event.PriceChanged;
 import com.ivanfranchin.bitcoinapi.price.model.Price;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -10,12 +10,12 @@
 @Slf4j
 @RequiredArgsConstructor
 @Component
-public class PriceEmitter {
+public class PriceEventEmitter {
 
     private final StreamBridge streamBridge;
 
     public void send(Price price) {
-        PriceMessage priceMessage = new PriceMessage(price.getId(), price.getValue(), price.getTimestamp());
+        PriceChanged priceMessage = new PriceChanged(price.getId(), price.getValue(), price.getTimestamp());
         streamBridge.send("prices-out-0", priceMessage);
         log.info("{} sent to bus.", priceMessage);
     }

bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/event/PriceChanged.java

@@ -0,0 +1,7 @@
+package com.ivanfranchin.bitcoinapi.price.event;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+
+public record PriceChanged(Long id, BigDecimal value, LocalDateTime timestamp) {
+}

bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/message/PriceMessage.java

@@ -1,6 +1,6 @@
 package com.ivanfranchin.bitcoinapi.scheduler;
 
-import com.ivanfranchin.bitcoinapi.price.PriceEmitter;
+import com.ivanfranchin.bitcoinapi.price.PriceEventEmitter;
 import com.ivanfranchin.bitcoinapi.price.model.Price;
 import com.ivanfranchin.bitcoinapi.price.PriceService;
 import lombok.RequiredArgsConstructor;
@@ -20,7 +20,7 @@
 public class PriceScheduler {
 
     private final PriceService priceService;
-    private final PriceEmitter priceStreamer;
+    private final PriceEventEmitter priceStreamer;
 
     @Scheduled(cron = "*/5 * * * * *") // every 5 seconds
     public void streamNewPrice() {

bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/scheduler/PriceScheduler.java

@@ -3,5 +3,5 @@
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 
-public record PriceMessage(Long id, BigDecimal value, LocalDateTime timestamp) {
+public record PriceChanged(Long id, BigDecimal value, LocalDateTime timestamp) {
 }

bitcoin-client/src/main/java/com/ivanfranchin/bitcoinclient/kafka/PriceMessage.java renamed to bitcoin-client/src/main/java/com/ivanfranchin/bitcoinclient/kafka/PriceChanged.java

@@ -16,16 +16,16 @@
 @Slf4j
 @RequiredArgsConstructor
 @Component
-public class PriceListener {
+public class PriceEventListener {
 
     private final SimpMessagingTemplate simpMessagingTemplate;
 
     @Bean
-    Consumer<Message<PriceMessage>> prices() {
+    Consumer<Message<PriceChanged>> prices() {
         return message -> {
-            PriceMessage priceMessage = message.getPayload();
+            PriceChanged priceMessage = message.getPayload();
             MessageHeaders messageHeaders = message.getHeaders();
-            log.info("PriceMessage with id {}, value '{}' and timestamp '{}' received from bus. topic: {}, partition: {}, offset: {}, deliveryAttempt: {}",
+            log.info("PriceChanged event with id {}, value '{}' and timestamp '{}' received. topic: {}, partition: {}, offset: {}, deliveryAttempt: {}",
                     priceMessage.id(), priceMessage.value(), priceMessage.timestamp(),
                     messageHeaders.get(KafkaHeaders.RECEIVED_TOPIC, String.class),
                     messageHeaders.get(KafkaHeaders.RECEIVED_PARTITION, Integer.class),