194. Jackson JMS Configuration. Closes #28

src/main/java/da/springframework/msscbeerservice/config/JmsConfig.java

@@ -1,5 +1,6 @@
 package da.springframework.msscbeerservice.config;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
@@ -14,10 +15,11 @@ public class JmsConfig {
 
     //Serialize message content to json using TextMessage
     @Bean
-    public MessageConverter meesageConverter(){
+    public MessageConverter meesageConverter(ObjectMapper objectMapper){
         MappingJackson2MessageConverter messageConverter = new MappingJackson2MessageConverter();
         messageConverter.setTargetType(MessageType.TEXT);
         messageConverter.setTypeIdPropertyName("_type");
+        messageConverter.setObjectMapper(objectMapper);
 
         return messageConverter;
     }

src/main/java/da/springframework/msscbeerservice/events/BeerEvent.java

@@ -1,18 +1,17 @@
 package da.springframework.msscbeerservice.events;
 
 import da.springframework.msscbeerservice.web.model.BeerDto;
-import lombok.Builder;
-import lombok.Data;
-import lombok.RequiredArgsConstructor;
+import lombok.*;
 
 import java.io.Serializable;
 
 @Data
-@RequiredArgsConstructor
+@AllArgsConstructor
+@NoArgsConstructor
 @Builder
 public class BeerEvent implements Serializable {
 
     static final long serialVersionUID = -7229137464711858491L;
 
-    private final BeerDto beerDto;
+    private BeerDto beerDto;
 }

src/main/java/da/springframework/msscbeerservice/events/BrewBeerEvent.java

@@ -2,7 +2,9 @@
 
 
 import da.springframework.msscbeerservice.web.model.BeerDto;
+import lombok.NoArgsConstructor;
 
+@NoArgsConstructor
 public class BrewBeerEvent extends BeerEvent {
 
     public BrewBeerEvent(BeerDto beerDto) {

src/main/java/da/springframework/msscbeerservice/events/NewInventoryEvent.java

@@ -1,7 +1,9 @@
 package da.springframework.msscbeerservice.events;
 
 import da.springframework.msscbeerservice.web.model.BeerDto;
+import lombok.NoArgsConstructor;
 
+@NoArgsConstructor
 public class NewInventoryEvent extends BeerEvent {
 
     public NewInventoryEvent(BeerDto beerDto) {

src/main/java/da/springframework/msscbeerservice/services/brewing/BrewBeerListener.java

@@ -11,15 +11,17 @@
 import org.springframework.jms.annotation.JmsListener;
 import org.springframework.jms.core.JmsTemplate;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @RequiredArgsConstructor
 @Slf4j
 public class BrewBeerListener {
 
-    private BeerRepository beerRepository;
-    private JmsTemplate jmsTemplate;
+    private final BeerRepository beerRepository;
+    private final JmsTemplate jmsTemplate;
 
+    @Transactional //cause there's no hibernate session
     @JmsListener(destination = JmsConfig.BREWING_REQUEST_QUEUE)
     public void listen(BrewBeerEvent brewBeerEvent){
         BeerDto beerDto = brewBeerEvent.getBeerDto();