wet 2 years ago
commit 0a291208c9

@ -50,6 +50,8 @@ namespace Myshipping.Application
var mqQueueName = $"{queueName}.{tenantId}";
logger.LogInformation("mqQueueName={que}", mqQueueName);
mqModel.QueueDeclare(mqQueueName, false, false, false, null);
mqModel.QueueBind(mqQueueName, ExchangeName, mqQueueName, null);
@ -64,7 +66,7 @@ namespace Myshipping.Application
mqModel.BasicPublish(ExchangeName,
queueName, props,
mqQueueName, props,
messageBodyBytes);
logger.LogInformation("MQ报文推送完成");

Loading…
Cancel
Save