com.lightbend.lagom.javadsl.broker.kafka

Class KafkaTopicFactory

Object

com.lightbend.lagom.javadsl.broker.kafka.KafkaTopicFactory

All Implemented Interfaces:

com.lightbend.lagom.internal.javadsl.api.broker.TopicFactory

public class KafkaTopicFactory
extends Object
implements com.lightbend.lagom.internal.javadsl.api.broker.TopicFactory

Factory for creating topics instances.

Constructor Summary

Constructors

Constructor and Description
KafkaTopicFactory(ServiceInfo serviceInfo, akka.actor.ActorSystem system, akka.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext, ServiceLocator serviceLocator)

Method Summary

Modifier and Type	Method and Description
<Message> Topic<Message>	create(Descriptor.TopicCall<Message> topicCall)

Methods inherited from class Object

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

Constructor Detail

KafkaTopicFactory

@Inject
public KafkaTopicFactory(ServiceInfo serviceInfo,
                                 akka.actor.ActorSystem system,
                                 akka.stream.Materializer materializer,
                                 scala.concurrent.ExecutionContext executionContext,
                                 ServiceLocator serviceLocator)

Method Detail

create

public <Message> Topic<Message> create(Descriptor.TopicCall<Message> topicCall)

Specified by:

create in interface com.lightbend.lagom.internal.javadsl.api.broker.TopicFactory