luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

removed unused argument idleTimeInMilliseconds

Browse source
This commit is contained in:
Ryan Pelaez 2025-02-04 13:21:34 -08:00
parent 08c874ad53
commit 2b055da2b5
4 changed files with 0 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ConsumerStates.java
View file

@ -263,7 +263,6 @@ class ConsumerStates {
throttlingReporter, throttlingReporter,
input, input,
argument.shouldCallProcessRecordsEvenForEmptyRecordList(), argument.shouldCallProcessRecordsEvenForEmptyRecordList(),
argument.idleTimeInMilliseconds(),
argument.aggregatorUtil(), argument.aggregatorUtil(),
argument.metricsFactory(), argument.metricsFactory(),
argument.schemaRegistryDecoder()); argument.schemaRegistryDecoder());

3
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ProcessTask.java
View file

@ -59,7 +59,6 @@ public class ProcessTask implements ConsumerTask {
private final Shard shard; private final Shard shard;
private final ThrottlingReporter throttlingReporter; private final ThrottlingReporter throttlingReporter;
private final boolean shouldCallProcessRecordsEvenForEmptyRecordList; private final boolean shouldCallProcessRecordsEvenForEmptyRecordList;
private final long idleTimeInMilliseconds;
private final ProcessRecordsInput processRecordsInput; private final ProcessRecordsInput processRecordsInput;
private final MetricsFactory metricsFactory; private final MetricsFactory metricsFactory;
private final AggregatorUtil aggregatorUtil; private final AggregatorUtil aggregatorUtil;
@ -76,7 +75,6 @@ public class ProcessTask implements ConsumerTask {
@NonNull ThrottlingReporter throttlingReporter, @NonNull ThrottlingReporter throttlingReporter,
ProcessRecordsInput processRecordsInput, ProcessRecordsInput processRecordsInput,
boolean shouldCallProcessRecordsEvenForEmptyRecordList, boolean shouldCallProcessRecordsEvenForEmptyRecordList,
long idleTimeInMilliseconds,
@NonNull AggregatorUtil aggregatorUtil, @NonNull AggregatorUtil aggregatorUtil,
@NonNull MetricsFactory metricsFactory, @NonNull MetricsFactory metricsFactory,
SchemaRegistryDecoder schemaRegistryDecoder) { SchemaRegistryDecoder schemaRegistryDecoder) {
@ -88,7 +86,6 @@ public class ProcessTask implements ConsumerTask {
this.throttlingReporter = throttlingReporter; this.throttlingReporter = throttlingReporter;
this.processRecordsInput = processRecordsInput; this.processRecordsInput = processRecordsInput;
this.shouldCallProcessRecordsEvenForEmptyRecordList = shouldCallProcessRecordsEvenForEmptyRecordList; this.shouldCallProcessRecordsEvenForEmptyRecordList = shouldCallProcessRecordsEvenForEmptyRecordList;
this.idleTimeInMilliseconds = idleTimeInMilliseconds;
this.metricsFactory = metricsFactory; this.metricsFactory = metricsFactory;
this.schemaRegistryDecoder = schemaRegistryDecoder; this.schemaRegistryDecoder = schemaRegistryDecoder;

1
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShardConsumerArgument.java
View file

@ -70,7 +70,6 @@ public class ShardConsumerArgument {
private final long listShardsBackoffTimeInMillis; private final long listShardsBackoffTimeInMillis;
private final int maxListShardsRetryAttempts; private final int maxListShardsRetryAttempts;
private final boolean shouldCallProcessRecordsEvenForEmptyRecordList; private final boolean shouldCallProcessRecordsEvenForEmptyRecordList;
private final long idleTimeInMilliseconds;
@NonNull @NonNull
private final InitialPositionInStreamExtended initialPositionInStream; private final InitialPositionInStreamExtended initialPositionInStream;

2
amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ProcessTaskTest.java
View file

@ -83,7 +83,6 @@ import static org.mockito.Mockito.when;
@RunWith(MockitoJUnitRunner.class) @RunWith(MockitoJUnitRunner.class)
public class ProcessTaskTest { public class ProcessTaskTest {
private static final long IDLE_TIME_IN_MILLISECONDS = 100L;
private static final Schema SCHEMA_REGISTRY_SCHEMA = new Schema("{}", "AVRO", "demoSchema"); private static final Schema SCHEMA_REGISTRY_SCHEMA = new Schema("{}", "AVRO", "demoSchema");
private static final byte[] SCHEMA_REGISTRY_PAYLOAD = new byte[] {01, 05, 03, 05}; private static final byte[] SCHEMA_REGISTRY_PAYLOAD = new byte[] {01, 05, 03, 05};
@ -157,7 +156,6 @@ public class ProcessTaskTest {
throttlingReporter, throttlingReporter,
processRecordsInput, processRecordsInput,
shouldCallProcessRecordsEvenForEmptyRecordList, shouldCallProcessRecordsEvenForEmptyRecordList,
IDLE_TIME_IN_MILLISECONDS,
aggregatorUtil, aggregatorUtil,
new NullMetricsFactory(), new NullMetricsFactory(),
schemaRegistryDecoder); schemaRegistryDecoder);