【发布时间】:2019-02-01 22:44:54
【问题描述】:
我不熟悉 AMQP。 我尝试将 AmqpNetLite 程序连接到 Qpid 服务器,但出现以下异常: Amqp.AmqpException: sasl-mechanisms(sasl-server-mechanisms:[CRAM-MD5,SCRAM-SHA-1,SCRAM-SHA-256])
注意:我可以连接到基本的 AMQP 服务器,但不能连接到 QPID。
这是创建连接的代码:
请告诉我从哪里开始解决我的问题。
void Main(string[] args)
{
try
{
Address address = new Address("amqp://guest:guest@localhost:5672");
Connection connection = new Connection(address);
Session session = new Session(connection);
ReceiverLink receiver = new ReceiverLink(session, "receiver-link", "queue");
Message message = receiver.Receive();
receiver.Accept(message);
receiver.Close();
session.Close();
connection.Close();
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
Console.ReadLine();
}
【问题讨论】:
-
您能否确认您使用的是哪个 Qpid 服务器实现(和版本)? Apache Qpid 项目有两个:Qpid CPP Broker 和 Qpid Broker-J(这是一个 Java 实现)。
-
Qpid Broker-J 版本:6.1 AmqpNetLite 2.1.6