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

Adding auto start up setter on sqsMessageDrivenChannelAdapter.java

Browse Source 
Update tests in SqsMessageDrivenChannelAdapterParserTests to invoke setAutoStartup

Change setAutoStartUp to invoke super in SqsMessageDrivenChannelAdapter

Add override to SqsMessageDrivenChannelAdapter

Remove call to setAutoStartup in SqsMessageDrivenChannelAdapterParserTests
This commit is contained in:
Patrick Fitzsimons
2016-06-07 18:30:05 +01:00
committed by Artem Bilan
parent 6abc1210a1
commit d2aa5224ec
2 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/springframework/integration/aws/inbound/SqsMessageDrivenChannelAdapter.java
View File

@@ -45,6 +45,7 @@ import com.amazonaws.services.sqs.AmazonSQSAsync;
* Works in 'listener' manner and delegates hard to the {@link SimpleMessageListenerContainer}.
*
* @author Artem Bilan
* @author Patrick Fitzsimons
*
* @see SimpleMessageListenerContainerFactory
* @see SimpleMessageListenerContainer
@@ -88,6 +89,12 @@ public class SqsMessageDrivenChannelAdapter extends MessageProducerSupport
this.simpleMessageListenerContainerFactory.setResourceIdResolver(resourceIdResolver);
}
@Override
public void setAutoStartup(boolean autoStartUp) {
super.setAutoStartup(autoStartUp);
this.simpleMessageListenerContainerFactory.setAutoStartup(autoStartUp);
}
public void setDestinationResolver(DestinationResolver<String> destinationResolver) {
this.simpleMessageListenerContainerFactory.setDestinationResolver(destinationResolver);
}

2
src/test/java/org/springframework/integration/aws/config/xml/SqsMessageDrivenChannelAdapterParserTests.java
View File

@@ -45,6 +45,7 @@ import com.amazonaws.services.sqs.AmazonSQS;
/**
* @author Artem Bilan
* @author Patrick Fitzsimons
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration
@@ -95,6 +96,7 @@ public class SqsMessageDrivenChannelAdapterParserTests {
assertThat(TestUtils.getPropertyValue(listenerContainer, "maxNumberOfMessages")).isEqualTo(5);
assertThat(TestUtils.getPropertyValue(listenerContainer, "visibilityTimeout")).isEqualTo(200);
assertThat(TestUtils.getPropertyValue(listenerContainer, "waitTimeOut")).isEqualTo(40);
assertThat(TestUtils.getPropertyValue(listenerContainer, "autoStartup")).isEqualTo(false);
@SuppressWarnings("rawtypes")
Map queues = TestUtils.getPropertyValue(listenerContainer, "registeredQueues", Map.class);