feat: create miranumMessageAdapter

example/example-core/src/main/java/io/miragon/example/adapter/out/MiranumMessageAdapter.java

@@ -0,0 +1,20 @@
+package io.miragon.example.adapter.out;
+
+import io.miragon.example.application.port.out.SendMessagePort;
+import io.miragon.miranum.connect.message.api.CorrelateMessageCommand;
+import io.miragon.miranum.connect.message.api.MessageApi;
+import lombok.RequiredArgsConstructor;
+
+import java.util.Map;
+
+@RequiredArgsConstructor
+public class MiranumMessageAdapter implements SendMessagePort {
+
+    private final MessageApi messageApi;
+
+    @Override
+    public void sendMessage(String messageName, String key, Map<String, Object> data) {
+        var command = new CorrelateMessageCommand(messageName, key, data);
+        messageApi.correlateMessage(command);
+    }
+}

example/example-core/src/main/java/io/miragon/example/application/port/out/SendMessagePort.java

@@ -4,5 +4,5 @@
 
 public interface SendMessagePort {
 
-    void sendMessage(final String messageName, final Map<String, Object> data);
+    void sendMessage(final String messageName, final String key, final Map<String, Object> data);
 }

example/example-core/src/main/java/io/miragon/example/application/service/SendMessageService.java

@@ -13,7 +13,7 @@ public class SendMessageService implements SendMessageUseCase {
 
     @Override
     public SendMessageResult sendMessage(SendMessageCommand command) {
-        sendMessagePort.sendMessage(command.getMessage(), null);
+        sendMessagePort.sendMessage(command.getMessage(), "key",  null);
         return new SendMessageResult("answer to: " + command.getMessage());
     }
 }