Fix connection to RabbitMQ.

Co-authored-by: William Karlström <112405777+lugn1@users.noreply.github.com>

Author: JesperBodin

docker-compose.yml

@@ -10,9 +10,9 @@ services:
     depends_on:
       - db
     environment:
-      SPRING_DATASOURCE_URL: jdbc:mysql://db:3306/userService
-      MYSQL_USER: developer
-      MYSQL_PASSWORD: password
+      DB_URL: jdbc:mysql://db:3306/userService
+      DB_USER: developer
+      DB_PASSWORD: password
 
   db:
     image: mysql:latest

…main/java/rabbitmq/RabbitMQListener.java …erservice/rabbitmq/RabbitMQListener.javasrc/main/java/rabbitmq/RabbitMQListener.java renamed to src/main/java/com/example/userservice/rabbitmq/RabbitMQListener.java src/main/java/rabbitmq/RabbitMQListener.java renamed to src/main/java/com/example/userservice/rabbitmq/RabbitMQListener.java

@@ -1,9 +1,11 @@
-package rabbitmq;
+package com.example.userservice.rabbitmq;
 
 import com.example.userservice.service.UserService;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.amqp.core.Queue;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 
 
@@ -16,6 +18,11 @@ public RabbitMQListener(UserService userService) {
         this.userService = userService;
     }
 
+    @Bean
+    public Queue myQueue(){
+        return new Queue("messages", false);
+    }
+
     @RabbitListener(queues = "messages")
     public void listenToMessageQueue(String jsonMessage) {
 
@@ -30,6 +37,4 @@ public void listenToMessageQueue(String jsonMessage) {
             System.out.println("Error in RabbitMQListener: " + e.getMessage());
         }
     }
-
-    // TODO: fix issue so it establish a connection to QueueRabbitMQ
 }

src/main/resources/application.properties

@@ -1,4 +1,4 @@
-spring.datasource.url=${DB_URL:jdbc:mysql://localhost:3306/userService}
+spring.datasource.url=${DB_URL:jdbc:mysql://db:3306/userService}
 spring.datasource.username=${DB_USER}
 spring.datasource.password=${DB_PASSWORD}
 spring.jpa.hibernate.ddl-auto=update