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

Merge pull request #82 from rankinc/shutdown-cloudwatch-metrics

Browse source 
Join metrics publishing thread when shutting factory down.
This commit is contained in:
Justin Pfifer 2016-07-21 09:57:57 -07:00 committed by GitHub
commit c936b63808
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/main/java/com/amazonaws/services/kinesis/metrics/impl/CWMetricsFactory.java
View file

@ -16,6 +16,7 @@ package com.amazonaws.services.kinesis.metrics.impl;
import java.util.Set;
import com.amazonaws.AbortedException;
import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.services.cloudwatch.AmazonCloudWatch;
@ -142,6 +143,11 @@ public class CWMetricsFactory implements IMetricsFactory {
public void shutdown() {
runnable.shutdown();
try {
publicationThread.join();
} catch (InterruptedException e) {
throw new AbortedException(e.getMessage(), e);
}
}
}