return this;
}
@Override public Response create(Subscription subscription)
throws AuthorizationException, ClientException, ServerException, InvalidException,
RateLimitException, NakadiException {
<BUG>NakadiException.throwNonNull(subscription, "Please provide a subscription");
PolicyBackoff backoff = ExponentialBackoff.newBuilder()
.initialInterval(900, TimeUnit.MILLISECONDS)
.maxAttempts(3)
.maxInterval(6000, TimeUnit.MILLISECONDS)
.build();</BUG>
return client.resourceProvider().newResource()

return this;
}
@Override public Response create(Subscription subscription)
throws AuthorizationException, ClientException, ServerException, InvalidException,
RateLimitException, NakadiException {
NakadiException.throwNonNull(subscription, "Please provide a subscription");
ResourceOptions options = prepareOptions(TokenProvider.NAKADI_EVENT_STREAM_READ);
PolicyBackoff backoff = policyBackoffForCreateOrUpdate();
return client.resourceProvider().newResource()
