Package | Description |
---|---|
io.simplesource.saga.action.async | |
io.simplesource.saga.action.eventsourcing | |
io.simplesource.saga.shared.topics |
Modifier and Type | Field and Description |
---|---|
TopicNamer |
AsyncContext.actionTopicNamer |
Modifier and Type | Field and Description |
---|---|
TopicNamer |
EventSourcingContext.actionTopicNamer |
TopicNamer |
EventSourcingContext.commandTopicNamer |
Modifier and Type | Field and Description |
---|---|
TopicNamer |
TopicConfig.namer
A functional interface that resolves the names of topics for a set of topics types.
|
Modifier and Type | Method and Description |
---|---|
static TopicNamer |
TopicNamer.forPrefix(String topicPrefix,
String baseName)
Creates a topic namer using the prefix resource naming strategy.
|
static TopicNamer |
TopicNamer.forStrategy(io.simplesource.kafka.api.ResourceNamingStrategy strategy,
String topicBaseName)
Creates a topic namer using a resource naming strategy.
|
static TopicNamer |
TopicUtils.topicNamerOverride(TopicNamer baseNamer,
Map<String,String> overrides) |
Modifier and Type | Method and Description |
---|---|
static TopicNamer |
TopicUtils.topicNamerOverride(TopicNamer baseNamer,
Map<String,String> overrides) |
TopicConfigBuilder |
TopicConfigBuilder.withTopicNamer(TopicNamer topicNamer)
Explicitly sets the topic namer
|
Copyright © 2019. All rights reserved.