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

Move throwOnIllegalState call to drain queue method to prevent improper error logging during worker shutdown

Browse source
This commit is contained in:
Zach Humpherys 2024-02-19 13:08:28 -08:00
parent a5d1c67660
commit 62061a2d2d
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/polling/PrefetchRecordsPublisher.java
View file

@ -289,7 +289,6 @@ public class PrefetchRecordsPublisher implements RecordsPublisher {
} }
private PrefetchRecordsRetrieved peekNextResult() { private PrefetchRecordsRetrieved peekNextResult() {
throwOnIllegalState();
return publisherSession.peekNextRecord(); return publisherSession.peekNextRecord();
} }
@ -389,6 +388,7 @@ public class PrefetchRecordsPublisher implements RecordsPublisher {
// If there is an event available to drain and if there is at least one demand, // If there is an event available to drain and if there is at least one demand,
// then schedule it for delivery // then schedule it for delivery
if (publisherSession.hasDemandToPublish() && canDispatchRecord(recordsToDeliver)) { if (publisherSession.hasDemandToPublish() && canDispatchRecord(recordsToDeliver)) {
throwOnIllegalState();
subscriber.onNext(recordsToDeliver.prepareForPublish()); subscriber.onNext(recordsToDeliver.prepareForPublish());
recordsToDeliver.dispatched(); recordsToDeliver.dispatched();
lastEventDeliveryTime = Instant.now(); lastEventDeliveryTime = Instant.now();