Browse Source

Update KafkaDistributedEventBus

pull/8829/head
liangshiwei 6 years ago
parent
commit
e0e659ae09
  1. 8
      framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs
  2. 12
      framework/src/Volo.Abp.EventBus.Rebus/Volo/Abp/EventBus/Rebus/AbpEventBusRebusOptionsSetup.cs

8
framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs

@ -76,10 +76,12 @@ namespace Volo.Abp.EventBus.Kafka
return; return;
} }
var eventMessage = Serializer.Deserialize(message.Value, eventType); var eventData = Serializer.Deserialize(message.Value, eventType);
await TriggerHandlersAsync(eventType, eventMessage, await TriggerHandlersAsync(eventType, eventData, errorContext =>
context => { context.SetProperty(KafkaEventErrorHandler.HeadersKey, message.Headers); }); {
errorContext.SetProperty(KafkaEventErrorHandler.HeadersKey, message.Headers);
});
} }
public IDisposable Subscribe<TEvent>(IDistributedEventHandler<TEvent> handler) where TEvent : class public IDisposable Subscribe<TEvent>(IDistributedEventHandler<TEvent> handler) where TEvent : class

12
framework/src/Volo.Abp.EventBus.Rebus/Volo/Abp/EventBus/Rebus/AbpEventBusRebusOptionsSetup.cs

@ -1,12 +0,0 @@
using Microsoft.Extensions.Options;
namespace Volo.Abp.EventBus.Rebus
{
public class AbpEventBusRebusOptionsSetup : IConfigureOptions<AbpEventBusOptions>
{
public void Configure(AbpEventBusOptions options)
{
throw new System.NotImplementedException();
}
}
}
Loading…
Cancel
Save