From 7a3a17fc88aec0d2f89443e5a467797d7e2c01cf Mon Sep 17 00:00:00 2001
From: fabian4 <fabian4@163.com>
Date: Thu, 24 Aug 2023 16:52:07 +0800
Subject: [PATCH] reproduce for https://github.com/apache/eventmesh/issues/4394

---
 eventmesh-runtime/build.gradle                     |  2 ++
 eventmesh-runtime/conf/eventmesh.properties        |  2 +-
 .../rabbitmq/producer/RabbitmqProducer.java        |  2 ++
 .../src/main/resources/rabbitmq-client.properties  | 14 +++++++-------
 4 files changed, 12 insertions(+), 8 deletions(-)

diff --git a/eventmesh-runtime/build.gradle b/eventmesh-runtime/build.gradle
index b24cd59a24..a13860f05c 100644
--- a/eventmesh-runtime/build.gradle
+++ b/eventmesh-runtime/build.gradle
@@ -38,6 +38,8 @@ dependencies {
     implementation project(":eventmesh-storage-plugin:eventmesh-storage-api")
     implementation project(":eventmesh-storage-plugin:eventmesh-storage-standalone")
     implementation project(":eventmesh-storage-plugin:eventmesh-storage-rocketmq")
+    implementation project(":eventmesh-storage-plugin:eventmesh-storage-rabbitmq")
+
     implementation project(":eventmesh-security-plugin:eventmesh-security-api")
     implementation project(":eventmesh-security-plugin:eventmesh-security-acl")
     implementation project(":eventmesh-security-plugin:eventmesh-security-auth-http-basic")
diff --git a/eventmesh-runtime/conf/eventmesh.properties b/eventmesh-runtime/conf/eventmesh.properties
index 73c3dfbb04..939bd4a8f6 100644
--- a/eventmesh-runtime/conf/eventmesh.properties
+++ b/eventmesh-runtime/conf/eventmesh.properties
@@ -75,7 +75,7 @@ eventMesh.server.blacklist.ipv6=::/128,::1/128,ff00::/8
 eventMesh.connector.plugin.type=standalone
 
 #storage plugin
-eventMesh.storage.plugin.type=standalone
+eventMesh.storage.plugin.type=rabbitmq
 
 #security plugin
 eventMesh.server.security.enabled=false
diff --git a/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducer.java b/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducer.java
index 4b12bce761..5597b4e738 100644
--- a/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducer.java
+++ b/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducer.java
@@ -95,6 +95,8 @@ public void init(Properties properties) throws Exception {
         this.connection = rabbitmqClient.getConnection(configurationHolder.getHost(), configurationHolder.getUsername(),
             configurationHolder.getPasswd(), configurationHolder.getPort(), configurationHolder.getVirtualHost());
         this.channel = rabbitmqConnectionFactory.createChannel(connection);
+        rabbitmqClient.binding(channel, configurationHolder.getExchangeType(), configurationHolder.getExchangeName(),
+                configurationHolder.getRoutingKey(), configurationHolder.getQueueName());
     }
 
     @Override
diff --git a/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties b/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties
index 0a282dff4e..8f2578a899 100644
--- a/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties
+++ b/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties
@@ -16,18 +16,18 @@
 #
 
 ####################### rabbitmq server ##################
-eventMesh.server.rabbitmq.host=127.0.0.1
+eventMesh.server.rabbitmq.host=host
 eventMesh.server.rabbitmq.port=5672
-eventMesh.server.rabbitmq.username=guest
-eventMesh.server.rabbitmq.passwd=guest
-eventMesh.server.rabbitmq.virtualHost=/
+eventMesh.server.rabbitmq.username=coyrqpyz
+eventMesh.server.rabbitmq.passwd=passwd
+eventMesh.server.rabbitmq.virtualHost=coyrqpyz
 
 ####################### rabbitmq queue setting ##################
 # DIRECT, FANOUT, TOPIC, HEADERS
 eventMesh.server.rabbitmq.exchangeType=TOPIC
-eventMesh.server.rabbitmq.exchangeName=eventmesh.default
-eventMesh.server.rabbitmq.routingKey=#
-eventMesh.server.rabbitmq.queueName=DefaultQueue
+eventMesh.server.rabbitmq.exchangeName=amq.topic
+eventMesh.server.rabbitmq.routingKey=eventmesh
+eventMesh.server.rabbitmq.queueName=eventmesh
 eventMesh.server.rabbitmq.autoAck=true
 
 ####################### rabbitmq management ##################