Spring/spring-integration-aws
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove amazon-kinesis-client

Browse Source 
* Remove the `amazon-kinesis-client` dependency
* Use `CustomizableThreadFactory` instead of `NamedThreadFactory`
This commit is contained in:
Marius Bogoevici
2017-01-25 09:46:57 -05:00
parent ef2f5f7aef
commit ace4055ed9
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
build.gradle
View File

@@ -91,8 +91,6 @@ dependencies {
compile("com.amazonaws:aws-java-sdk-kinesis:$awsSdkVersion", optional)
compile("com.amazonaws:amazon-kinesis-client:1.7.0", optional)
compile("javax.servlet:javax.servlet-api:$servletApiVersion", provided)
testCompile "org.springframework.integration:spring-integration-test:$springIntegrationVersion"

6
src/main/java/org/springframework/integration/aws/inbound/kinesis/KinesisMessageDrivenChannelAdapter.java
View File

@@ -47,11 +47,11 @@ import org.springframework.integration.support.management.IntegrationManagedReso
import org.springframework.jmx.export.annotation.ManagedOperation;
import org.springframework.jmx.export.annotation.ManagedResource;
import org.springframework.scheduling.SchedulingAwareRunnable;
import org.springframework.scheduling.concurrent.CustomizableThreadFactory;
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;
import com.amazonaws.services.kinesis.AmazonKinesis;
import com.amazonaws.services.kinesis.clientlibrary.utils.NamedThreadFactory;
import com.amazonaws.services.kinesis.model.DescribeStreamRequest;
import com.amazonaws.services.kinesis.model.DescribeStreamResult;
import com.amazonaws.services.kinesis.model.GetRecordsRequest;
@@ -231,7 +231,7 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
if (this.consumerExecutor == null) {
this.consumerExecutor = Executors.newCachedThreadPool(
new NamedThreadFactory((getComponentName() == null
new CustomizableThreadFactory((getComponentName() == null
? ""
: getComponentName())
+ "-kinesis-consumer-"));
@@ -239,7 +239,7 @@ public class KinesisMessageDrivenChannelAdapter extends MessageProducerSupport i
if (this.dispatcherExecutor == null) {
this.dispatcherExecutor =
Executors.newCachedThreadPool(
new NamedThreadFactory((getComponentName() == null
new CustomizableThreadFactory((getComponentName() == null
? ""
: getComponentName())
+ "-kinesis-dispatcher-"));