java/amazon-kinesis-producer/src/main/java/com/amazonaws/services/kinesis/producer/KinesisProducer.java [604:611]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        FutureTask<String> task = null;
        if(config.getUserRecordTimeoutInMillis() > 0) {
            task = new FutureTask(new FutureTimeoutRunnableTask(id), "TimedOut");
            futureTimeoutExecutor.schedule(task, config.getUserRecordTimeoutInMillis(), TimeUnit.MILLISECONDS);
        }
        SettableFutureTracker futuresTracking = new SettableFutureTracker(f, Instant.now(), Optional.ofNullable(task));
        futures.put(id, futuresTracking);
        oldestFutureTrackerHeap.add(futuresTracking);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/amazon-kinesis-producer/src/main/java/com/amazonaws/services/kinesis/producer/KinesisProducer.java [729:736]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        FutureTask<String> task = null;
        if(config.getUserRecordTimeoutInMillis() > 0) {
            task = new FutureTask(new FutureTimeoutRunnableTask(id), "TimedOut");
            futureTimeoutExecutor.schedule(task, config.getUserRecordTimeoutInMillis(), TimeUnit.MILLISECONDS);
        }
        SettableFutureTracker futuresTracking = new SettableFutureTracker(f, Instant.now(), Optional.ofNullable(task));
        futures.put(id, futuresTracking);
        oldestFutureTrackerHeap.add(futuresTracking);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -