fix(referral): add EventAckPublisher to InfrastructureModule
- Refactor EventAckPublisher to use KafkaService instead of ClientKafka - Add kafka/index.ts export file - Register EventAckPublisher in InfrastructureModule providers and exports 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
parent
dfa21c0280
commit
807dc8705d
|
|
@ -2,3 +2,4 @@ export * from './database';
|
||||||
export * from './repositories';
|
export * from './repositories';
|
||||||
export * from './messaging';
|
export * from './messaging';
|
||||||
export * from './cache';
|
export * from './cache';
|
||||||
|
export * from './kafka';
|
||||||
|
|
|
||||||
|
|
@ -0,0 +1 @@
|
||||||
|
export * from './event-ack.publisher';
|
||||||
|
|
@ -7,6 +7,7 @@ import {
|
||||||
KafkaService,
|
KafkaService,
|
||||||
EventPublisherService,
|
EventPublisherService,
|
||||||
RedisService,
|
RedisService,
|
||||||
|
EventAckPublisher,
|
||||||
} from '../infrastructure';
|
} from '../infrastructure';
|
||||||
import {
|
import {
|
||||||
REFERRAL_RELATIONSHIP_REPOSITORY,
|
REFERRAL_RELATIONSHIP_REPOSITORY,
|
||||||
|
|
@ -21,6 +22,7 @@ import {
|
||||||
KafkaService,
|
KafkaService,
|
||||||
RedisService,
|
RedisService,
|
||||||
EventPublisherService,
|
EventPublisherService,
|
||||||
|
EventAckPublisher,
|
||||||
{
|
{
|
||||||
provide: REFERRAL_RELATIONSHIP_REPOSITORY,
|
provide: REFERRAL_RELATIONSHIP_REPOSITORY,
|
||||||
useClass: ReferralRelationshipRepository,
|
useClass: ReferralRelationshipRepository,
|
||||||
|
|
@ -35,6 +37,7 @@ import {
|
||||||
KafkaService,
|
KafkaService,
|
||||||
RedisService,
|
RedisService,
|
||||||
EventPublisherService,
|
EventPublisherService,
|
||||||
|
EventAckPublisher,
|
||||||
REFERRAL_RELATIONSHIP_REPOSITORY,
|
REFERRAL_RELATIONSHIP_REPOSITORY,
|
||||||
TEAM_STATISTICS_REPOSITORY,
|
TEAM_STATISTICS_REPOSITORY,
|
||||||
],
|
],
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue