reproduce for apache#4394

fabian4 · Aug 24, 2023 · 7a3a17f · 7a3a17f
1 parent 62c22e0
commit 7a3a17f
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 8 deletions.
diff --git 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
@@ -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/...bbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducer.java b/...bbitmq/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/...h-storage-plugin/eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties b/...h-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 ##################