This commit is contained in:
李鹏军 2024-03-19 14:39:09 +08:00
parent d3a4f81c65
commit 9cca8dedc4
3 changed files with 3 additions and 3 deletions

View File

@ -25,7 +25,7 @@ public class TrackDeleteEventHandler : ITransientDependency, ICapSubscribe
_trackDetailsRepository = trackDetailsRepository; _trackDetailsRepository = trackDetailsRepository;
} }
[CapSubscribe(GlobalConst.TrackDeleteSubscribe)] [CapSubscribe(GlobalConst.TrackDeleteSubscribe, Group = GlobalConst.TrackDeleteSubscribe)]
public async Task ConsumerAsync(TrackDeleteEvent @event) public async Task ConsumerAsync(TrackDeleteEvent @event)
{ {
if (@event.Visited.Contains(@event.OrderId)) if (@event.Visited.Contains(@event.OrderId))

View File

@ -22,7 +22,7 @@ public class TrackPushEventHandler : ITransientDependency, ICapSubscribe
_capPublisher = capPublisher; _capPublisher = capPublisher;
} }
[CapSubscribe(GlobalConst.TrackPushSubscribe)] [CapSubscribe(GlobalConst.TrackPushSubscribe, Group = GlobalConst.TrackPushSubscribe)]
public async Task ConsumerAsync(TrackPushEvent @event) public async Task ConsumerAsync(TrackPushEvent @event)
{ {
InterfaceRelayUnifyResultDto res = null!; InterfaceRelayUnifyResultDto res = null!;

View File

@ -33,7 +33,7 @@ public class TrackUpsertEventHandler : ITransientDependency, ICapSubscribe
_trackPushCacheService = trackPushCacheService; _trackPushCacheService = trackPushCacheService;
} }
[CapSubscribe(GlobalConst.TrackUpsertSubscribe)] [CapSubscribe(GlobalConst.TrackUpsertSubscribe, Group = GlobalConst.TrackUpsertSubscribe)]
public async Task ConsumerAsync(TrackUpsertEvent @event) public async Task ConsumerAsync(TrackUpsertEvent @event)
{ {
if (@event.Visited.Contains(@event.OrderId)) if (@event.Visited.Contains(@event.OrderId))