/**
* Copyright 2016-2017 ZTE, Inc. and others.
*
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
*
- * http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
*
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
*/
package org.onap.msb.sdclient.wrapper.consul.option;
public static final QueryOptions BLANK = ImmutableQueryOptions.builder().build();
public abstract Optional<String> getWait();
+
public abstract Optional<String> getToken();
+
public abstract Optional<BigInteger> getIndex();
+
public abstract Optional<String> getNear();
-
+
public ConsistencyMode getConsistencyMode() {
return ConsistencyMode.DEFAULT;
}
}
private static ImmutableQueryOptions.Builder blockBuilder(String identifier, int qty, BigInteger index) {
- return ImmutableQueryOptions.builder()
- .wait(String.format("%s%s", qty, identifier))
- .index(index);
+ return ImmutableQueryOptions.builder().wait(String.format("%s%s", qty, identifier)).index(index);
}
@Override
}
if (isBlocking()) {
- added = added.queryParam("wait", getWait().get())
- .queryParam("index", String.valueOf(getIndex().get()));
+ added = added.queryParam("wait", getWait().get()).queryParam("index", String.valueOf(getIndex().get()));
}
added = optionallyAdd(added, "token", getToken());