adding rabbitmq services.

publishers/src/main/java/br/com/bscpaz/publisher/configurations/RabbitmqConfig.java

@@ -0,0 +1,8 @@
+package br.com.bscpaz.publisher.configurations;
+
+public class RabbitmqConfig {
+
+    public static final String JUSTICE_V1_DOCS_EXCHANGE = "justice.v1.documents";
+    public static final String JUSTICE_V1_DOCS_ROUTING_KEY = "document-signed.";
+
+}

publishers/src/main/java/br/com/bscpaz/publisher/controllers/dtos/ResponseDTO.java

@@ -14,19 +14,19 @@ public class ResponseDTO<T> {
 
     private String message;
 
-    private T result;
+    private T payload;
 
     public ResponseDTO() {
     }
 
     public ResponseDTO(boolean isSuccess, T t) {
         this.isSuccess = isSuccess;
-        this.result = t;
+        this.payload = t;
     }
 
     public ResponseDTO(boolean isSuccess, String message, T t) {
         this.isSuccess = isSuccess;
         this.message = message;
-        this.result = t;
+        this.payload = t;
     }
 }

publishers/src/main/java/br/com/bscpaz/publisher/controllers/utils/ResponseUtil.java

@@ -7,13 +7,23 @@
 
 public class ResponseUtil {
 
-    public static <T> ResponseEntity<ResponseDTO<T>> success(T conteudo) {
-        ResponseDTO<T> dto = new ResponseDTO<T>(true, conteudo);
+    public static <T> ResponseEntity<ResponseDTO<T>> success(T payload) {
+        ResponseDTO<T> dto = new ResponseDTO<T>(true, payload);
         return new ResponseEntity<>(dto, HttpStatus.OK);
     }
 
-    public static <T> ResponseEntity<ResponseDTO<T>> badRequest(T conteudo, String mensage) {
-        ResponseDTO<T> dto = new ResponseDTO<T>(false, mensage, conteudo);
+    public static <T> ResponseEntity<ResponseDTO<T>> success(String message, T payload) {
+        ResponseDTO<T> dto = new ResponseDTO<T>(true, message, payload);
+        return new ResponseEntity<>(dto, HttpStatus.OK);
+    }
+
+    public static <T> ResponseEntity<ResponseDTO<T>> badRequest(T payload, String message) {
+        ResponseDTO<T> dto = new ResponseDTO<T>(false, message, payload);
         return new ResponseEntity<>(dto, HttpStatus.BAD_REQUEST);
     }
+
+    public static <T> ResponseEntity<ResponseDTO<T>> internalServerError(T payload, String message) {
+        ResponseDTO<T> dto = new ResponseDTO<T>(false, message, payload);
+        return new ResponseEntity<>(dto, HttpStatus.INTERNAL_SERVER_ERROR);
+    }
 }

publishers/src/main/java/br/com/bscpaz/publisher/controllers/v1/impl/BasicPublisherControllerImpl.java

@@ -1,18 +1,27 @@
 package br.com.bscpaz.publisher.controllers.v1.impl;
 
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.RestController;
 
 import br.com.bscpaz.publisher.controllers.dtos.ResponseDTO;
 import br.com.bscpaz.publisher.controllers.utils.ResponseUtil;
 import br.com.bscpaz.publisher.controllers.v1.BasicPublisherController;
+import br.com.bscpaz.publisher.services.BasicPublisherService;
 
 @RestController
 public class BasicPublisherControllerImpl implements BasicPublisherController {
 
+    @Autowired
+    private BasicPublisherService basicPublisherController;
+
     @Override
     public ResponseEntity<ResponseDTO<String>> helloWorldRabbitmq() {
-        return ResponseUtil.success("Message published into rabbitmq!");
+        try {
+            String message = basicPublisherController.helloWorldRabbitmq();
+            return ResponseUtil.success(message, null);
+        } catch (Exception e) {
+            return ResponseUtil.internalServerError(e.getMessage(), "Sorry, something went wrong.");
+        }
     }
-
 }

publishers/src/main/java/br/com/bscpaz/publisher/services/BasicPublisherService.java

@@ -0,0 +1,6 @@
+package br.com.bscpaz.publisher.services;
+
+public interface BasicPublisherService {
+
+    String helloWorldRabbitmq();
+}

publishers/src/main/java/br/com/bscpaz/publisher/services/impl/BasicPublisherServiceImpl.java

@@ -0,0 +1,29 @@
+package br.com.bscpaz.publisher.services.impl;
+
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import br.com.bscpaz.publisher.configurations.RabbitmqConfig;
+import br.com.bscpaz.publisher.services.BasicPublisherService;
+
+@Service
+public class BasicPublisherServiceImpl implements BasicPublisherService {
+
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+
+    @Override
+    public String helloWorldRabbitmq() {
+        String helloWorld = "Hello World";
+        Message message = new Message(helloWorld.getBytes());
+
+        rabbitTemplate.send(
+            RabbitmqConfig.JUSTICE_V1_DOCS_EXCHANGE, 
+            RabbitmqConfig.JUSTICE_V1_DOCS_ROUTING_KEY + "1",
+            message);
+
+        return "Message has been sent to RabbitMQ!";
+    }
+}

publishers/src/main/resources/application.yml

@@ -0,0 +1,7 @@
+spring:
+    rabbitmq:
+      host: localhost
+      port: 5672
+      username: system_user
+      password: 123456
+      virtual-host: justice-prd