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

make tries configurable as in HttpAction

Browse Source
This commit is contained in:
Enrico Olivelli 2021-03-17 18:01:30 +01:00
parent abbea4df71
commit 84a9a4bf83
1 changed files with 3 additions and 2 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/PulsarAction.java
View File

@ -13,13 +13,14 @@ public class PulsarAction implements SyncAction {
private final static Logger logger = LogManager.getLogger(PulsarAction.class); private final static Logger logger = LogManager.getLogger(PulsarAction.class);
private static final int MAX_TRIALS = 100;
private final int slot; private final int slot;
private final PulsarActivity activity; private final PulsarActivity activity;
int maxTries = 1;
public PulsarAction(PulsarActivity activity, int slot) { public PulsarAction(PulsarActivity activity, int slot) {
this.activity = activity; this.activity = activity;
this.slot = slot; this.slot = slot;
this.maxTries = activity.getActivityDef().getParams().getOptionalInteger("maxtries").orElse(10);
} }
@Override @Override
@ -42,7 +43,7 @@ public class PulsarAction implements SyncAction {
); );
} }
for (int i = 0; i < MAX_TRIALS; i++) { for (int i = 0; i < maxTries; i++) {
try (Timer.Context ctx = activity.getExecuteTimer().time()) { try (Timer.Context ctx = activity.getExecuteTimer().time()) {
pulsarOp.run(); pulsarOp.run();
break; break;