amazon-sqs-java-messaging-lib

amazon-sqs-java-messaging-lib copied to clipboard

Set individual message delays

1

I've just started using the new feature to add delays in #76 but I'd like to set the delay on a per message basis instead of the whole MessageProducer. I've...

stanley-travelex

I'm wondering why this exception occurs every time we close the connection: ERROR [ConsumerPrefetchThread-75] SQSSession - Interrupted while closing the session. java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2067) at java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1475) at java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:675) at com.amazon.sqs.javamessaging.SQSSession.doClose(SQSSession.java:434)...

dastraka

I have upgraded my spring boot api version from 2.0 to 2.2.0 and java version from 8 to 11 . Post above up-gradation I am unable to consume the SQS...

sjhameenakshi

Would I be able to set visibility timeout for message using amazon sqs jms lib?

4

I have multiple threads running concurrently. And since one message's execution might be dependent on another, after checking state of previous message's execution state, I want the message to remain...

pratikshya

Change WAIT_TIME_SECONDS in SQSMessageConsumerPrefetch

2

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...

sidath80

Support SQS messages with Type Binary and Number

8

The SQS documentation indicates that messages with "Type" of "Number" and "Binary" are valid, see https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-attributes.html This PR adds support for these "Type" values. According to https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/sqs-message-attributes.html > Number –...

candrews

SQSSession recover causes listener threads to block one another

2

We are seeing a issue where our jms listener threads end up blocking each other when the SQSSession#recover throws a Exception. The exception occurs in the recover process where it...

thorxiong-nm

JMS Listener threads block one another after deleteMessage failure

3

After a couple of days and thousands of successfully processed messages our JMS message listener encountered a server-side AWS error. While attempting to recover it blocked all of the threads...

justinfalk

Custom message attribute types cause JMS Exception...

8

We had a bunch of messages in an SQS queue where the messageAttribute data types were not recognized by the code with SQSMessage. private static Object getObjectValue(String value, String type)...

jwindberg

#81 *Description of changes:* Add async send methods to SQSMessageProducer

Mobe91