Merge pull request #3 from rabbitmq/filter-size

Add --filter-size

Author: acogoluegnes

src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java

@@ -429,6 +429,13 @@ public class StreamPerfTest implements Callable<Integer> {
  split = ",")
  private List<String> filterValues;
 
+ @CommandLine.Option(
+ names = {"--filter-size", "-fs"},
+ description = "filter size, between 16 and 255",
+ defaultValue = "16",
+ converter = Utils.GreaterThanOrEqualToZeroIntegerTypeConverter.class)
+ private int filterSize;
+
  @CommandLine.Option(
  names = {"--force-replica-for-consumers", "-frfc"},
  description = "force the connection to a replica for consumers",
@@ -1226,6 +1233,7 @@ private void createStream(Environment environment, String stream) {
  StreamCreator streamCreator =
  environment.streamCreator().stream(stream)
  .maxSegmentSizeBytes(this.maxSegmentSize)
+ .filterSize(this.filterSize)
  .leaderLocator(this.leaderLocator);
 
  if (this.maxLengthBytes.toBytes() != 0) {