|
|
@@ -23,7 +23,8 @@ class RabbitMQ {
|
|
|
|
|
|
try {
|
|
|
await channel.assertExchange(exchange, 'direct', { durable: true });
|
|
|
- console.log("生产者发送消息:",exchange,routingKey,msg)
|
|
|
+ // console.log("生产者发送消息:",exchange,routingKey,msg)
|
|
|
+ console.log("生产者发送消息:",exchange,routingKey)
|
|
|
channel.publish(exchange, routingKey, Buffer.from(JSON.stringify(msg)));
|
|
|
} catch (error) {
|
|
|
console.error('发送消息错误:', error);
|
