使用SQS/SNS的MassTransit。未发布到SQS队列的消息

Question

我试图使用他们文档中提到的masstransit配置将SNS主题订阅到SQS队列。消息已发布，但不会出现在SQS队列中。SQS队列名称：“测试”，SNS主题名称：“kbbico手动替换”。

public void ConfigureServices(IServiceCollection services)
        {
            services.AddControllers();

            services.AddMassTransit(x =>
            {
                /*Configuring a receive endpoint will use the message topology to create and subscribe SNS topics to SQS queues so that 
                 * published messages will be delivered to the receive endpoint queue*/
                x.AddConsumer<OfferConsumer>();
                x.UsingAmazonSqs((context, cfg) =>
                {
                    cfg.Host("ca-central-1", h =>
                    {
                        //h.Config(AmazonSQSConfig);
                        //h.Config(AmazonSnsConfig);                     
                    });

                    cfg.ReceiveEndpoint("test", e =>
                    {
                        e.ConfigureConsumer<OfferConsumer>(context);
                        // disable the default topic binding
                        //e.ConfigureConsumeTopology = false;

                        //Topic subscibed to a recieve endpoint
                        e.Subscribe("kbbico-manual-to-replace", s =>
                        {
                            // set topic attributes
                            s.TopicAttributes["DisplayName"] = "Public Event Topic";
                            s.TopicSubscriptionAttributes["some-subscription-attribute"] = "some-attribute-value";
                            s.TopicTags.Add("environment", "development");
                        });
                    });
                    cfg.ConfigureEndpoints(context);
                });


            });
            services.AddMassTransitHostedService();
        }

Answer 1

您没有配置消费者，因此消息可能被移动到_skipped队列（或者可能是SQS DLQ）。

此外，cfg。主机配置中的ConfigureEndpoints（）根本不属于那里。它应该出现在总线配置的最后。