amazon-sqs-java-messaging-lib
amazon-sqs-java-messaging-lib copied to clipboard
Change WAIT_TIME_SECONDS in SQSMessageConsumerPrefetch
Hi All,
I need to change the value of the WAIT_TIME_SECONDS in SQSMessageConsumerPrefetch to less than 10 seconds.Currently it is 20s.
I am using following code to create the SQS listener ,
SQSConnectionFactory connectionFactory = new SQSConnectionFactory( new ProviderConfiguration(), AmazonSQSClientBuilder.standard() .withCredentials( new InstanceProfileCredentialsProvider(false))
);
@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
DefaultJmsListenerContainerFactory factory =
new DefaultJmsListenerContainerFactory();
factory.setConnectionFactory(this.connectionFactory);
factory.setDestinationResolver(new DynamicDestinationResolver());
factory.setConcurrency("3-10");
return factory;
}
Thank you Sid
Looks like it was fixed https://github.com/awslabs/amazon-sqs-java-messaging-lib/pull/140
I feel that rather than using Reflection to set this value, this should be configurable via properties.