diff --git a/backend/services/referral-service/src/infrastructure/index.ts b/backend/services/referral-service/src/infrastructure/index.ts index cb51e191..d1ee8cd6 100644 --- a/backend/services/referral-service/src/infrastructure/index.ts +++ b/backend/services/referral-service/src/infrastructure/index.ts @@ -2,3 +2,4 @@ export * from './database'; export * from './repositories'; export * from './messaging'; export * from './cache'; +export * from './kafka'; diff --git a/backend/services/referral-service/src/infrastructure/kafka/index.ts b/backend/services/referral-service/src/infrastructure/kafka/index.ts new file mode 100644 index 00000000..be96c4c6 --- /dev/null +++ b/backend/services/referral-service/src/infrastructure/kafka/index.ts @@ -0,0 +1 @@ +export * from './event-ack.publisher'; diff --git a/backend/services/referral-service/src/modules/infrastructure.module.ts b/backend/services/referral-service/src/modules/infrastructure.module.ts index 44f796f5..bfcb48bc 100644 --- a/backend/services/referral-service/src/modules/infrastructure.module.ts +++ b/backend/services/referral-service/src/modules/infrastructure.module.ts @@ -7,6 +7,7 @@ import { KafkaService, EventPublisherService, RedisService, + EventAckPublisher, } from '../infrastructure'; import { REFERRAL_RELATIONSHIP_REPOSITORY, @@ -21,6 +22,7 @@ import { KafkaService, RedisService, EventPublisherService, + EventAckPublisher, { provide: REFERRAL_RELATIONSHIP_REPOSITORY, useClass: ReferralRelationshipRepository, @@ -35,6 +37,7 @@ import { KafkaService, RedisService, EventPublisherService, + EventAckPublisher, REFERRAL_RELATIONSHIP_REPOSITORY, TEAM_STATISTICS_REPOSITORY, ],