Skip to content

Commit

Permalink
use constant names in listener
Browse files Browse the repository at this point in the history
  • Loading branch information
hknots committed Sep 19, 2024
1 parent 759759f commit c501efa
Showing 1 changed file with 5 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,9 @@
import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
import org.springframework.stereotype.Service;

import static no.fintlabs.provider.kafka.TopicNamesConstants.ADAPTER_REGISTER_EVENT_NAME;
import static no.fintlabs.provider.kafka.TopicNamesConstants.FINT_CORE;

@Slf4j
@Service
@RequiredArgsConstructor
Expand All @@ -39,8 +42,8 @@ public ConcurrentMessageListenerContainer<String, AdapterContract> registerAdapt
EventTopicNamePatternParameters
.builder()
.orgId(FormattedTopicComponentPattern.any())
.domainContext(FormattedTopicComponentPattern.anyOf("fint-core"))
.eventName(ValidatedTopicComponentPattern.endingWith("adapter-register"))
.domainContext(FormattedTopicComponentPattern.anyOf(FINT_CORE))
.eventName(ValidatedTopicComponentPattern.endingWith(ADAPTER_REGISTER_EVENT_NAME))
.build()
);
}
Expand Down

0 comments on commit c501efa

Please sign in to comment.