IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

Minor code change - change method name from IsBoolean() to isBoolean()

Browse Source
This commit is contained in:
Yabin Meng 2021-03-10 12:34:02 -06:00
parent 3ad3cc6b70
commit f1a15230e8
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java
View File

@ -9,7 +9,6 @@ import org.apache.commons.lang3.StringUtils;
import org.apache.pulsar.client.api.Producer;
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.Reader;
import org.apache.pulsar.client.api.Schema;
import java.util.function.LongFunction;
import java.util.function.Supplier;
@ -55,7 +54,7 @@ public class ReadyPulsarOp implements LongFunction<PulsarOp> {
return opFunc.apply(value);
}
private boolean IsBoolean (String str) {
private boolean isBoolean(String str) {
return StringUtils.equalsAnyIgnoreCase(str, "yes", "true");
}
@ -103,7 +102,7 @@ public class ReadyPulsarOp implements LongFunction<PulsarOp> {
LongFunction<Boolean> asyncApiFunc;
if ( cmdTpl.containsKey("async_api") ) {
if ( cmdTpl.isStatic("async_api") )
asyncApiFunc = (l) -> IsBoolean(cmdTpl.getStatic("async_api"));
asyncApiFunc = (l) -> isBoolean(cmdTpl.getStatic("async_api"));
else
throw new RuntimeException("\"async_api\" parameter cannot be dynamic!");
}