0
我创建了一个使用MassTransit和Azure服务总线作为传输工具的应用程序。发布,发送,检索事件和命令 - 这一切都很好。但是现在我想创建订阅者来检索发布者在用户连接后发送的消息。怎么做?我不想在连接之前获取发布商发送的所有消息。检索发布者在用户连接后发送的邮件(masstransit)
我创建了一个使用MassTransit和Azure服务总线作为传输工具的应用程序。发布,发送,检索事件和命令 - 这一切都很好。但是现在我想创建订阅者来检索发布者在用户连接后发送的消息。怎么做?我不想在连接之前获取发布商发送的所有消息。检索发布者在用户连接后发送的邮件(masstransit)
你所要求的是不可能的。
根据定义,发布者只发送给订阅者。如果用户在事件发布时没有连接,那么该用户将不会收到它。只有在事件发布时连接的订户才会收到事件。
未来,MassTransit将增加对Kafka和Event Hub的支持,它将支持你想要的功能,但这些传输的语义是完全不同的。
根据天气情况,Event Hub的早期支持可能会在下周完成...... –
我已经测试过了。步骤: 1.关闭用户 2.发送来自发布者的消息 3.打开的用户 结果:我有订阅者的消息。 这就像你说的,如果我创建新的订户(与新的队列)。 –
@АлександрГребенюк这是正确的。一旦用户连接一次,当断开时消息将在队列上建立起来,并在重新连接时可用。 –