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) Deprecated. As of release 1.6.0. Use KafkaTopicFactory(ServiceInfo, ActorSystem, Materializer, ExecutionContext, ServiceLocator, Config) instead.
KafkaTopicFactory(ServiceInfo serviceInfo, akka.actor.ActorSystem system, akka.stream.Materializer materializer, scala.concurrent.ExecutionContext executionContext, ServiceLocator serviceLocator, com.typesafe.config.Config config)

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

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

Deprecated. As of release 1.6.0. Use KafkaTopicFactory(ServiceInfo, ActorSystem, Materializer, ExecutionContext, ServiceLocator, Config) instead.

KafkaTopicFactory

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

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