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

Class endpoints.Subscribe

java.lang.Object

com.here.platform.data.client.service.stream.endpoints.Subscribe

All Implemented Interfaces:

Api, Endpoint, RestEndpoint, StreamApi, Serializable, scala.Equals, scala.Product

Enclosing class:

endpoints

public static final class endpoints.Subscribe
extends Object
implements RestEndpoint, StreamApi, scala.Product, Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Subscribe(String layer, String groupId, Offset offset, String consumerId)

Method Summary

Modifier and Type	Method	Description
String	consumerId()
String	groupId()
scala.Option<org.apache.pekko.http.scaladsl.model.RequestEntity>	httpEntity()
String	layer()
org.apache.pekko.http.scaladsl.model.HttpMethod	method()
Offset	offset()
String	path()
scala.collection.immutable.Map<String,scala.collection.immutable.Seq<String>>	query()
scala.collection.immutable.Set<org.apache.pekko.http.scaladsl.model.StatusCode>	retriableHttpStatusCodes()
scala.concurrent.duration.FiniteDuration	retriesDeadline(RetryPolicyType retryPolicyType)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.here.platform.data.client.http.Endpoint

acceptableNonSuccessStatusCodes, forceStrict, headers, isStreamingRequest, maxWaitingTimeBetweenRetries, perRequestTimeout

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Methods inherited from interface com.here.platform.data.client.http.RestEndpoint

acceptHeader, asHttpRequest, createParamMap, queryAsSeq

Methods inherited from interface com.here.platform.data.client.service.stream.StreamApi

apiType

Constructor Details

Subscribe

public Subscribe(String layer,
 String groupId,
 Offset offset,
 String consumerId)

Method Details

layer

public String layer()

groupId

public String groupId()

offset

public Offset offset()

consumerId

public String consumerId()

method

public org.apache.pekko.http.scaladsl.model.HttpMethod method()

Specified by:

method in interface Endpoint

path

public String path()

Specified by:

path in interface RestEndpoint

query

public scala.collection.immutable.Map<String,scala.collection.immutable.Seq<String>> query()

Specified by:

query in interface RestEndpoint

httpEntity

public scala.Option<org.apache.pekko.http.scaladsl.model.RequestEntity> httpEntity()

Specified by:

httpEntity in interface Endpoint

retriableHttpStatusCodes

public scala.collection.immutable.Set<org.apache.pekko.http.scaladsl.model.StatusCode> retriableHttpStatusCodes()

Specified by:

retriableHttpStatusCodes in interface Endpoint

retriesDeadline

public scala.concurrent.duration.FiniteDuration retriesDeadline(RetryPolicyType retryPolicyType)

Specified by:

retriesDeadline in interface Endpoint