Package io.micronaut.pulsar.processor

Interface TopicResolver

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface TopicResolver

Process input string to determine real topic name for Apache Pulsar. Allows flexibility by avoiding requirement to hardcode full topic names into the code. Useful in scenarios like multi-tenant applications.

Since:

1.2.0

Author:

Haris Secic

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	TopicResolver.TopicResolved	Simple container class for describing resolved topics.

Method Summary

Modifier and Type	Method	Description
static @NonNull TopicResolver.TopicResolved	extractTopic(io.micronaut.core.annotation.AnnotationValue<?> pulsarAnnotation, String forName)
default String	generateIdFromMessagingClientName(String name, TopicResolver.TopicResolved topicResolved)
static boolean	isDynamicTenantInTopic(String topic)
static String	replaceTenantInTopic(String topic, String tenant)
String	resolve(String topic)

Method Details

resolve

String resolve(String topic)

generateIdFromMessagingClientName

default String generateIdFromMessagingClientName(String name,
 TopicResolver.TopicResolved topicResolved)

replaceTenantInTopic

static String replaceTenantInTopic(String topic,
 String tenant)

isDynamicTenantInTopic

static boolean isDynamicTenantInTopic(String topic)

extractTopic

@NonNull
static @NonNull TopicResolver.TopicResolved extractTopic(io.micronaut.core.annotation.AnnotationValue<?> pulsarAnnotation,
 String forName)