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

Class DefaultStreamConfigProvider

java.lang.Object

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

All Implemented Interfaces:

StreamConfigProvider

public class DefaultStreamConfigProvider
extends Object
implements StreamConfigProvider

Constructor Summary

Constructors

Constructor	Description
DefaultStreamConfigProvider(RequestResponseHandler requestResponseHandler, 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

DefaultStreamConfigProvider

public DefaultStreamConfigProvider(RequestResponseHandler requestResponseHandler,
 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