Skip to content

Commit 3ed3ff7

Browse files
Merge pull request #213 from SethPyle376/master
Fixes type mismatch when using "confirm" parameter in json
2 parents 649c482 + a76a076 commit 3ed3ff7

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/com/rabbitmq/perf/MulticastParams.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636

3737
public class MulticastParams {
3838

39-
private long confirm = -1;
39+
private int confirm = -1;
4040
private int confirmTimeout = 30;
4141
private int consumerCount = 1;
4242
private int producerCount = 1;
@@ -181,7 +181,7 @@ public void setConsumerTxSize(int consumerTxSize) {
181181
this.consumerTxSize = consumerTxSize;
182182
}
183183

184-
public void setConfirm(long confirm) {
184+
public void setConfirm(int confirm) {
185185
this.confirm = confirm;
186186
}
187187

src/main/java/com/rabbitmq/perf/PerfTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ public static void main(String [] args, PerfTestOptions perfTestOptions) {
102102
int consumerChannelCount = intArg(cmd, 'Y', 1);
103103
int producerTxSize = intArg(cmd, 'm', 0);
104104
int consumerTxSize = intArg(cmd, 'n', 0);
105-
long confirm = intArg(cmd, 'c', -1);
105+
int confirm = intArg(cmd, 'c', -1);
106106
int confirmTimeout = intArg(cmd, "ct", 30);
107107
boolean autoAck = hasOption(cmd,"a");
108108
int multiAckEvery = intArg(cmd, 'A', 0);

0 commit comments

Comments
 (0)