MassTransit-启动总线时AmazonMQ出现套接字异常



我正试图使用我们的Amazon MQ实例让一个基本的PoC应用程序与MassTransit一起运行,当我在IBusControl上调用StartAsync时遇到以下问题:

MassTransit.ActiveMqTransport.ActiveMqConnectException:连接异常:(用户(@(host--->Apache.NMS.NMSConnectionException:连接到(主机(时出错--->System.Net.Sockets.SocketException(0xFFFFFFFE(:未知错误(0xFFFFFFFE(在Apache.NMS.ActiveMQ.Transport.Tcp.TcpTransportFactory.DoConnect(字符串主机,Int32端口,字符串本地地址,Int32本地端口(

注意:在上面的异常中,我用粗体编辑了项目以删除敏感信息。我们知道,我们使用的凭据实际上是正确的,因为我们对使用相同凭据的NMS和ActiveMq进行了集成测试。但是,当尝试使用MassTransit进行连接时,我们会出现上述错误。

我尝试了许多不同的方法,但它们都产生了相同的结果。以下是一些示例代码,大致介绍了我们如何连接:

var busControl = Bus.Factory.CreateUsingActiveMq(configurator =>
{
configurator.Host(host, activeMqHostConfigurator =>
{
activeMqHostConfigurator.Username(activeMqConfiguration.UserName);
activeMqHostConfigurator.Password(activeMqConfiguration.Password);
});
});
await busControl.StartAsync(new CancellationTokenSource(TimeSpan.FromSeconds(10)).Token);

对StartAsync的调用引发异常。我怀疑这是MassTransit的问题,这很可能是我遗漏的东西,但我看不出出出了什么问题,我也让我的团队进行了审查。

正如我在评论中提到的,这最终与MassTransit无关。这是由于主机处于非活动状态。

相关内容

最新更新