Transfer.Pulsar - dotnet-shashlik/shashlik.eventbus GitHub Wiki

Pulsar

Nuget: Shashlik.EventBus.Pulsar

注册Pulsar消息传输

        /// <summary>
        /// 使用配置节点初始化Pulsar
        /// </summary>
        /// <param name="eventBusBuilder"></param>
        /// <param name="configurationSection"></param>
        /// <returns></returns>
        public static AddPulsar AddRabbitMQ(this IEventBusBuilder eventBusBuilder, IConfigurationSection configurationSection);

        /// <summary>
        /// 手动配置Pulsar数据
        /// </summary>
        /// <param name="eventBusBuilder"></param>
        /// <param name="action"></param>
        /// <returns></returns>
        public static IEventBusBuilder AddPulsar(this IEventBusBuilder eventBusBuilder, Action<EventBusKafkaOptions> action);

        /// <summary>
        /// 注册Pulsar核心服务
        /// </summary>
        /// <param name="eventBusBuilder"></param>
        /// <returns></returns>
        public static IEventBusBuilder AddPulsarCore(this IEventBusBuilder eventBusBuilder)

配置项

  • ServiceUrl:服务地址,默认值pulsar://localhost
  • PulsarClientFactory:pulsar client实例获取工厂,比ServiceUrl优先级更高,默认值null
⚠️ **GitHub.com Fallback** ⚠️