io.simplesource.kafka.util

Class PrefixResourceNamingStrategy

java.lang.Object

io.simplesource.kafka.util.PrefixResourceNamingStrategy

All Implemented Interfaces:

ResourceNamingStrategy

public final class PrefixResourceNamingStrategy
extends Object
implements ResourceNamingStrategy

Constructor Summary

Constructors

Constructor and Description
PrefixResourceNamingStrategy()
PrefixResourceNamingStrategy(String prefix)
PrefixResourceNamingStrategy(String prefix, String separator)

Method Summary

Modifier and Type	Method and Description
String	topicName(String aggregateName, String topicEntity) Generate the Kafka topic name to use for a given aggregate domain.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PrefixResourceNamingStrategy

public PrefixResourceNamingStrategy()

PrefixResourceNamingStrategy

public PrefixResourceNamingStrategy(String prefix)

PrefixResourceNamingStrategy

public PrefixResourceNamingStrategy(String prefix,
                                    String separator)

Method Detail

topicName

public String topicName(String aggregateName,
                        String topicEntity)

Description copied from interface: ResourceNamingStrategy

Generate the Kafka topic name to use for a given aggregate domain.

Specified by:

topicName in interface ResourceNamingStrategy

Parameters:

aggregateName - name of the domain aggregate

topicEntity - entities stored in this topic

Returns:

name of the Kafka topic to use