private/internal method - has package level access solely for testing purposes . concode_field_sep IRecordProcessor recordProcessor concode_elem_sep ICheckpoint checkpoint concode_elem_sep KinesisDataFetcher dataFetcher concode_elem_sep StreamConfig streamConfig concode_elem_sep ExecutorService executorService concode_elem_sep ILeaseManager<KinesisClientLease> leaseManager concode_elem_sep ITask currentTask concode_elem_sep long currentTaskSubmitTime concode_elem_sep ShardInfo shardInfo concode_elem_sep long taskBackoffTimeMillis concode_elem_sep boolean cleanupLeasesOfCompletedShards concode_elem_sep boolean skipShardSyncAtWorkerInitializationIfLeasesExist concode_elem_sep Future<TaskResult> future concode_elem_sep RecordProcessorCheckpointer recordProcessorCheckpointer concode_elem_sep ShutdownReason shutdownReason concode_elem_sep ShutdownNotification shutdownNotification concode_elem_sep ConsumerStates.ConsumerState currentState concode_elem_sep Log LOG concode_elem_sep IMetricsFactory metricsFactory concode_elem_sep long parentShardPollIntervalMillis concode_field_sep void logTaskException concode_elem_sep boolean isShutdownRequested concode_elem_sep IRecordProcessor getRecordProcessor concode_elem_sep StreamConfig getStreamConfig concode_elem_sep boolean readyForNextTask concode_elem_sep ITask getNextTask concode_elem_sep boolean beginShutdown concode_elem_sep KinesisDataFetcher getDataFetcher concode_elem_sep ShutdownReason getShutdownReason concode_elem_sep RecordProcessorCheckpointer getRecordProcessorCheckpointer concode_elem_sep void markForShutdown concode_elem_sep void updateState concode_elem_sep ILeaseManager<KinesisClientLease> getLeaseManager concode_elem_sep long getTaskBackoffTimeMillis concode_elem_sep ExecutorService getExecutorService concode_elem_sep long getParentShardPollIntervalMillis concode_elem_sep TaskOutcome determineTaskOutcome concode_elem_sep ShutdownNotification getShutdownNotification concode_elem_sep boolean isCleanupLeasesOfCompletedShards concode_elem_sep Future<TaskResult> getFuture concode_elem_sep boolean consumeShard concode_elem_sep ICheckpoint getCheckpoint concode_elem_sep boolean isSkipShardSyncAtWorkerInitializationIfLeasesExist concode_elem_sep ShardInfo getShardInfo concode_elem_sep boolean checkAndSubmitNextTask concode_elem_sep void notifyShutdownRequested concode_elem_sep boolean isShutdown
ConsumerStates . ShardConsumerState function ( ) { return currentState . getState ( ) ; }