我想创建一个订阅服务器,用于侦听现有的exchange以及使用MassTransit和RabbitMq绑定到该exchange的队列。环境详情: dotnet版本: 4.8 MassTransit版本: 7.1.3
请在下面找到我的订户代码:
using System;
using System.Threading.Tasks;
using Contracts;
using MassTransit;
namespace Subscriber
{
internal class Receive
{
public static async Task Main(str
每次我将AMQP队列绑定到交换时,它似乎自动绑定到“默认”直接交换。
下面是使用rabbitMQ服务器和node.js的代码:
var amqp = require('amqp');
var connection = amqp.createConnection({host:'localhost'});
connection.on('ready', function(){
var q = connection.queue('test_queue_name');
var exc = connection.excha