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

emit metric

Browse source
This commit is contained in:
Wei 2017-09-29 14:49:11 -07:00
parent abed367da0
commit 6ab1503fe3
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/PrefetchGetRecordsCache.java
View file

@ -119,9 +119,9 @@ public class PrefetchGetRecordsCache implements GetRecordsCache {
log.warn("Prefetch thread was interrupted."); log.warn("Prefetch thread was interrupted.");
break; break;
} }
MetricsHelper.startScope(metricsFactory, "ProcessTask");
if (prefetchCounters.shouldGetNewRecords()) { if (prefetchCounters.shouldGetNewRecords()) {
try { try {
MetricsHelper.startScope(metricsFactory, "Prefetcheing");
GetRecordsResult getRecordsResult = getRecordsRetrievalStrategy.getRecords(maxRecordsPerCall); GetRecordsResult getRecordsResult = getRecordsRetrievalStrategy.getRecords(maxRecordsPerCall);
ProcessRecordsInput processRecordsInput = new ProcessRecordsInput() ProcessRecordsInput processRecordsInput = new ProcessRecordsInput()
.withRecords(getRecordsResult.getRecords()) .withRecords(getRecordsResult.getRecords())
@ -131,6 +131,8 @@ public class PrefetchGetRecordsCache implements GetRecordsCache {
prefetchCounters.added(processRecordsInput); prefetchCounters.added(processRecordsInput);
} catch (InterruptedException e) { } catch (InterruptedException e) {
log.info("Thread was interrupted, indicating shutdown was called on the cache"); log.info("Thread was interrupted, indicating shutdown was called on the cache");
} finally {
MetricsHelper.endScope();
} }
} }
} }