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

Join metrics publishing thread when shutting factory down.

Browse source
This commit is contained in:
Chris Rankin 2016-06-27 22:47:48 +01:00
parent 6d3ffff870
commit f4849baa42
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 java.util.Set;
import com.amazonaws.AbortedException;
import com.amazonaws.ClientConfiguration; import com.amazonaws.ClientConfiguration;
import com.amazonaws.auth.AWSCredentialsProvider; import com.amazonaws.auth.AWSCredentialsProvider;
import com.amazonaws.services.cloudwatch.AmazonCloudWatch; import com.amazonaws.services.cloudwatch.AmazonCloudWatch;
@ -142,6 +143,11 @@ public class CWMetricsFactory implements IMetricsFactory {
public void shutdown() { public void shutdown() {
runnable.shutdown(); runnable.shutdown();
try {
publicationThread.join();
} catch (InterruptedException e) {
throw new AbortedException(e.getMessage(), e);
}
} }
} }