Skip to content

Commit 9fd1eaf

Browse files
A S Adil MohammadA S Adil Mohammad
authored andcommitted
feat: Some tweaks for optimisation
Signed-off-by: A S Adil Mohammad <asadilmohammad2020@gmail.com>
1 parent 0b82867 commit 9fd1eaf

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/ibm/eventstreams/connect/mqsource/MQSourceTask.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -425,7 +425,7 @@ private List<Message> pollSourceQueue(final int numberOfMessagesToBePolled) thro
425425
}
426426

427427
log.debug("Polling for records");
428-
final long startTime = System.currentTimeMillis();
428+
final long pollEndTime = System.currentTimeMillis() + maxPollTime;
429429

430430
Message message;
431431
do {
@@ -437,7 +437,7 @@ private List<Message> pollSourceQueue(final int numberOfMessagesToBePolled) thro
437437
message != null &&
438438
localList.size() < numberOfMessagesToBePolled &&
439439
!stopNow.get() &&
440-
(maxPollTime <= 0 || (System.currentTimeMillis() - startTime) < maxPollTime)
440+
(maxPollTime <= 0 || System.currentTimeMillis() < pollEndTime)
441441
);
442442

443443
return localList;

0 commit comments

Comments
 (0)