public class KafkaTopicFactory extends Object implements com.lightbend.lagom.internal.javadsl.api.broker.TopicFactory
Constructor and Description |
---|
KafkaTopicFactory(ServiceInfo serviceInfo,
akka.actor.ActorSystem system,
akka.stream.Materializer materializer,
scala.concurrent.ExecutionContext executionContext,
ServiceLocator serviceLocator) |
Modifier and Type | Method and Description |
---|---|
<Message> Topic<Message> |
create(Descriptor.TopicCall<Message> topicCall) |
@Inject public KafkaTopicFactory(ServiceInfo serviceInfo, akka.actor.ActorSystem system, akka.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext, ServiceLocator serviceLocator)
public <Message> Topic<Message> create(Descriptor.TopicCall<Message> topicCall)
create
in interface com.lightbend.lagom.internal.javadsl.api.broker.TopicFactory