fabian4 commented on issue #4394: URL: https://github.com/apache/eventmesh/issues/4394#issuecomment-1691361346
I think the problem is in producer. We should bind the channel with routeKey and exchangeName when we init the producer connection otherwise there is no message in the queue to consume. (But we actually do bind it when we init the consumer connection. @Pil0tXia  https://github.com/apache/eventmesh/blob/fd1102ac04644e1e22e2c2cda11038a0819d8520/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducer.java#L92-L98 https://github.com/apache/eventmesh/blob/fd1102ac04644e1e22e2c2cda11038a0819d8520/eventmesh-storage-plugin/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/consumer/RabbitmqConsumer.java#L113-L118 https://github.com/apache/eventmesh/blob/fd1102ac04644e1e22e2c2cda11038a0819d8520/eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/sink/connector/RabbitMQSinkConnector.java#L77-L84 https://github.com/apache/eventmesh/blob/fd1102ac04644e1e22e2c2cda11038a0819d8520/eventmesh-connectors/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/source/connector/RabbitMQSourceConnector.java#L99-L107 --- > Was it fixed by your modifications here? @fabian4 > https://github.com/apache/eventmesh/commit/3f1783f6abc58722e14f85d673e3f5c42ca4fa4d @pandaapo This is to roll back the change I have made when I do some local test. It's irrelevant. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
