介绍
sbus是用于通过AMQP连接到Azure Service Bus服务的库。
当前,仅支持事件中心,并且可以通过以下两种方法之一进行访问:
按个别分区
通过整个eventhub(称为事件处理器)
该库通过采用AMQP提供程序并将其包装在更高级别的操作和连接管理中进行操作,以使其易于针对Azure EventHub运行。 它也可以将状态存储到Azure表存储中,从而提供无缝的功能来继续从您离开的位置(类似于.NET EventProcessorHost)接收消息。
用法
要使用此库,您需要为其提供AMQP提供程序实现(请参见下文),然后可以按以下方式对其进行访问:
要接收来自所有分区的消息myEventHub在myServiceBus和存储状态myTableStore ,与AMQP提供AMQPProviderImpl :
// Set up variables
var se
评论0
最新资源