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 and Description
static class	TopicResolver.TopicResolved Simple container class for describing resolved topics.

Method Summary

Modifier and Type	Method and Description
static TopicResolver.TopicResolved	extractTopic(io.micronaut.core.annotation.AnnotationValue<?> pulsarAnnotation)
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 Detail

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 TopicResolver.TopicResolved extractTopic(io.micronaut.core.annotation.AnnotationValue<?> pulsarAnnotation)