io.simplesource.saga.shared.topics

Class TopicConfig

java.lang.Object

io.simplesource.saga.shared.topics.TopicConfig

public final class TopicConfig
extends Object

TopicConfig represents configuration information for topic names and for topic properties for topic creation

It ensures that the topic names for a family of topics are consistent

Examples of families of topics are:

• Action topics for a given action type (request, response etc)
• Saga topics (request, response as well as saga state and transitions)

See TopicTypes for complete lists of topic families.

Field Summary

Fields

Modifier and Type	Field and Description
TopicNamer	namer A functional interface that resolves the names of topics for a set of topics types.
Map<String,io.simplesource.kafka.spec.TopicSpec>	topicSpecs A map of topic specs per action type.
List<String>	topicTypes A list of topic types that this topic config applies to the family of topics

Constructor Summary

Constructors

Constructor and Description
TopicConfig()

Method Summary

Modifier and Type	Method and Description
List<TopicCreation>	allTopics() Builds a list of topic creations, which contains both the topic namer and the topic spec

Methods inherited from class java.lang.Object

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

Field Detail

namer

public final TopicNamer namer

A functional interface that resolves the names of topics for a set of topics types.

topicTypes

public final List<String> topicTypes

A list of topic types that this topic config applies to the family of topics

topicSpecs

public final Map<String,io.simplesource.kafka.spec.TopicSpec> topicSpecs

A map of topic specs per action type. The topic spec defines the properties required for topic creation

Constructor Detail

TopicConfig

public TopicConfig()

Method Detail

allTopics

public final List<TopicCreation> allTopics()

Builds a list of topic creations, which contains both the topic namer and the topic spec

Returns:

the list of topic creations