Refactoring code with adding producer class

Author: lawalk

spring-boot-api-with-activemq/src/main/java/com/javatodev/api/configuration/JmsConfiguration.java

@@ -1,26 +1,46 @@
 package com.javatodev.api.configuration;
 
 import jakarta.jms.ConnectionFactory;
+import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.jms.annotation.EnableJms;
 import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
+import org.springframework.jms.config.JmsListenerContainerFactory;
+import org.springframework.jms.support.converter.MappingJackson2MessageConverter;
+import org.springframework.jms.support.converter.MessageConverter;
+import org.springframework.jms.support.converter.MessageType;
 
 @Configuration
 @EnableJms
 public class JmsConfiguration {
 
     /**
-     * Set the connection with the ActiveMQ
+     * Create JMS Connection Factory
      * @param connectionFactory
-     * @return JmsListenerContainerFactory
+     * @param configurer
+     * @return Connection Factory
      */
     @Bean
-    public DefaultJmsListenerContainerFactory defaultJmsListenerContainerFactory(ConnectionFactory connectionFactory){
-        DefaultJmsListenerContainerFactory defaultJmsListenerContainerFactory = new DefaultJmsListenerContainerFactory();
-        defaultJmsListenerContainerFactory.setConnectionFactory(connectionFactory);
-        // Set concurrency with minimum 5 consumers and automatically scale up to maximum of 10 consumers
-        defaultJmsListenerContainerFactory.setConcurrency("5-10");
-        return defaultJmsListenerContainerFactory;
+    public JmsListenerContainerFactory<?> jmsFactory(ConnectionFactory connectionFactory,
+                                                     DefaultJmsListenerContainerFactoryConfigurer configurer) {
+        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
+        factory.setMessageConverter(jacksonJmsMessageConverter());
+        configurer.configure(factory, connectionFactory);
+        return factory;
     }
+
+    /**
+     * Serialize message content to json using TextMessage
+     *
+     * @return Message Converter
+     */
+    @Bean
+    public MessageConverter jacksonJmsMessageConverter() {
+        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
+        converter.setTargetType(MessageType.TEXT);
+        converter.setTypeIdPropertyName("_asb_");
+        return converter;
+    }
+
 }

spring-boot-api-with-activemq/src/main/java/com/javatodev/api/consumer/StoreMessageConsumer.java

@@ -13,8 +13,8 @@ public class StoreMessageConsumer {
      * Message Listener of ActiveMQ queue
      * @param store
      */
-    @JmsListener(destination = "store_msg_queue")
-    public void messageListener(Store store){
-        log.info("Message Received. {}",store);
+    @JmsListener(destination = "${activemq.destination}", containerFactory = "jmsFactory")
+    public void processToDo(Store store) {
+        log.info("Consumer> " + store);
     }
 }

spring-boot-api-with-activemq/src/main/java/com/javatodev/api/controller/StoreMessageController.java

@@ -1,9 +1,9 @@
 package com.javatodev.api.controller;
 
 import com.javatodev.api.dto.Store;
+import com.javatodev.api.producer.StoreMessageProducer;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.jms.core.JmsTemplate;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -17,18 +17,20 @@ public class StoreMessageController {
     @Autowired
     private JmsTemplate jmsTemplate;
 
+    @Autowired
+    StoreMessageProducer storeMessageProducer;
+
+    @Value("${activemq.destination}")
+    private String destination;
+
     /**
      * API for publish message for ActiveMQ queue
      * @param store
-     * @return ResponseEntity
+     * @return String
      */
     @PostMapping("/publish")
-    public ResponseEntity<String> publishMessage(@RequestBody Store store){
-        try {
-            jmsTemplate.convertAndSend("store_msg_queue", store);
-            return new ResponseEntity<>("Request Sent", HttpStatus.OK);
-        }catch (Exception e){
-            return new ResponseEntity<>(e.getMessage(), HttpStatus.INTERNAL_SERVER_ERROR);
-        }
+    public String publishMessage(@RequestBody Store store){
+        storeMessageProducer.sendTo(destination,store);
+        return "Success";
     }
 }

spring-boot-api-with-activemq/src/main/java/com/javatodev/api/dto/Store.java

@@ -1,25 +1,15 @@
 package com.javatodev.api.dto;
 
-import lombok.Data;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
 
-import java.io.Serializable;
-
-@Data
-public class Store implements Serializable {
-
-    private static final long serialVersionUID = 1L;
+@Getter
+@Setter
+@ToString
+public class Store{
 
     private int itemId;
     private String itemName;
     private int itemQuantity;
-
-    @Override
-    public String toString(){
-        return "Store{" +
-                "item id ='"+ itemId +'\'' +
-                ", item Name ='"+ itemName + '\'' +
-                ", item Quantity ='"+ itemQuantity + '\'' +
-                "}";
-
-    }
 }

spring-boot-api-with-activemq/src/main/java/com/javatodev/api/producer/StoreMessageProducer.java

@@ -0,0 +1,27 @@
+package com.javatodev.api.producer;
+
+import com.javatodev.api.dto.Store;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jms.core.JmsTemplate;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class StoreMessageProducer {
+
+    @Autowired
+    private JmsTemplate jmsTemplate;
+
+    /**
+     * Convert and publish the message to the queue
+     *
+     * @param destination
+     * @param store
+     */
+    public void sendTo(String destination, Store store) {
+        jmsTemplate.convertAndSend(destination, store);
+        log.info("Producer> Message Sent");
+    }
+
+}

spring-boot-api-with-activemq/src/main/resources/application.properties

@@ -3,4 +3,5 @@ server.port = 8089
 spring.activemq.broker-url=tcp://localhost:61616
 spring.activemq.user=admin
 spring.activemq.password=admin
-spring.activemq.packages.trust-all=true 
+
+activemq.destination=store