我正在尝试新的MassTransitIJobConsumer实现，尽管我已经尝试按照文档进行操作，但我编写的JobConsumer从未运行/命中。
我有：

• 我创建了JobConsumer，它有一个run方法，可以运行我需要它运行的代码

public class CalculationStartRunJobConsumer : IJobConsumer<ICalculationStartRun> 
  {
      private readonly ICalculationRunQueue runQueue;

      public CalculationStartRunJobConsumer(ICalculationRunQueue runQueue)
      {
          this.runQueue = runQueue;
      }

      public Task Run(JobContext<ICalculationStartRun> context)
      {
          return Task.Run(
              () =>
              {
                  var longRunningJob = new LongRunningJob<ICalculationStartRun>
                  {
                      Job = context.Job,
                      CancellationToken = context.CancellationToken,
                      JobId = context.JobId,
                  };

                  runQueue.StartSpecial(longRunningJob);
              },
              context.CancellationToken);
      } 
  }

• 我已注册该消费者尝试使用ConnectReceiveEndpoint和AddConsumer
• 已按文档中所示配置ServiceInstance

services.AddMassTransit(busRegistrationConfigurator =>
      {
          // TODO: Get rid of this ugly if statement.
          if (consumerTypes != null)
          {
              foreach (var consumerType in consumerTypes)
              {
                  busRegistrationConfigurator.AddConsumer(consumerType);
              }
          }

          if(requestClientType != null)
          {
              busRegistrationConfigurator.AddRequestClient(requestClientType);
          }

          busRegistrationConfigurator.UsingRabbitMq((context, cfg) =>
          {
              cfg.UseNewtonsoftJsonSerializer();
              cfg.UseNewtonsoftJsonDeserializer();
              cfg.ConfigureNewtonsoftJsonSerializer(settings =>
              {
                  // The serializer by default omits fields that are set to their default value, but this causes unintended effects
                  settings.NullValueHandling = NullValueHandling.Include;
                  settings.DefaultValueHandling = DefaultValueHandling.Include;
                  return settings;
              });

              cfg.Host(
                  messagingHostInfo.HostAddress,
                  hostConfigurator =>
                  {
                      hostConfigurator.Username(messagingHostInfo.UserName);
                      hostConfigurator.Password(messagingHostInfo.Password);
                  });

              cfg.ServiceInstance(instance =>
              {
                  instance.ConfigureJobServiceEndpoints(serviceCfg =>
                  {
                      serviceCfg.FinalizeCompleted = true;
                  });

                  instance.ConfigureEndpoints(context);
              });
          });
      });

• 看到作业队列确实出现在RabbitMQ队列中
• 当我调用.Send向该队列发送消息时，它不会激活JobConsumer上的Run方法。

public async Task Send<T>(string queueName, T message) where T : class
  {
      var endpointUri = GetEndpointUri(messagingHostInfo.HostAddress, queueName);
      var sendEndpoint = await bus.GetSendEndpoint(endpointUri);

      await sendEndpoint.Send(message);
  }

有人能帮忙吗？

软件

• x1m11 n1个8.0.2英寸
• x1米12英寸1英寸8.0.2英寸
• x1米13英寸1x 8.0.2英寸
• .NET6个
• 将内存中用于JobConsumer