Package com.here.platform.data.client.service.stream

Class EmbeddedStreamConfigProvider

java.lang.Object

com.here.platform.data.client.service.stream.EmbeddedStreamConfigProvider

All Implemented Interfaces:

StreamConfigProvider

public class EmbeddedStreamConfigProvider
extends Object
implements StreamConfigProvider

Constructor Summary

Constructors

Constructor	Description
EmbeddedStreamConfigProvider(com.typesafe.config.Config dataClientConfiguration, ClientExecutionContext clientExecutionContext)

Method Summary

Modifier and Type	Method	Description
scala.concurrent.Future<KafkaStreamSettings>	getKafkaNotificationSettings(HRN hrn, InternalSettings internalSettings)
scala.concurrent.Future<KafkaStreamSettings>	getKafkaSettings(HRN hrn, String layerId, InternalSettings internalSettings)

Methods inherited from class java.lang.Object

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

Constructor Details

EmbeddedStreamConfigProvider

public EmbeddedStreamConfigProvider(com.typesafe.config.Config dataClientConfiguration,
 ClientExecutionContext clientExecutionContext)

Method Details

getKafkaNotificationSettings

public scala.concurrent.Future<KafkaStreamSettings> getKafkaNotificationSettings(HRN hrn,
 InternalSettings internalSettings)

Specified by:

getKafkaNotificationSettings in interface StreamConfigProvider

getKafkaSettings

public scala.concurrent.Future<KafkaStreamSettings> getKafkaSettings(HRN hrn,
 String layerId,
 InternalSettings internalSettings)

Specified by:

getKafkaSettings in interface StreamConfigProvider