I’m trying to implement a queue through SQS for my project, sending to the queue works just fine, but receiving from the queue isn’t working at all. It seems the receiver has absolutely no connection to the queue at all Config Consumer Method Maven Dependencies I’ve gone through numerous Stack Overflow posts on the topic already, haven’t found a solution.
Tag: amazon-sqs
Send cross AWS account message from Lambda to SQS
I want to send a message to SQS queue on another account (Ohio) from lambda in North Virginia account. How can I achieve this? Things I tried so far: Created a queue in Ohio and gave lambda role arn to the queue. Sent message from the lambda in North Virigina , got following error: “errorMessage”: “An error occurred (AWS.SimpleQueueService.NonExistentQueue) when
AWS SQS – MessageConsumer stops to receive messages after a while
My application registers a listeners to a SQS queue (queue itself is populated by a SNS topic). When I start the application, message consumer is working as expected but after a while it stops to receive any messages. Can it be that consumer is shutting down after a while? Suggestions or comments would be much appreciated. SQSConnection: Consummer: Answer You’re
How the function changeMessageVisibility of sqs message extends the visibility time?
In its documentation of ChangeMessageVisibility function, Amazon gives the following example: For example, you have a message with a visibility timeout of 5 minutes. After 3 minutes, you call ChangeMessageVisibility with a timeout of 10 minutes. You can continue to call ChangeMessageVisibility to extend the visibility timeout to the maximum allowed time. If you try to extend the visibility timeout
SQS FIFO Using MessageGroupId to receive message
How do I use the messagegroupid parameter to only receive queue messages tagged with the id I need? I’ve been trying to use the line below to retrieve but it will always receive all the queue messages from other group id as well. List<Message> messages = sqs.receiveMessage(receiveMessageRequest.withAttributeNames(“MessageGroupId”)).getMessages(); What should be the correct way to do it? Answer The ReceiveMessageRequest is
How to connect to SQS queue
I have created several SQS queues in the management console. All the queues have full access permission (Allow – Everybody – All SQS Actions) I have created necessary credentials and can connect to AWS. Now I am trying to connect to created queues: But nothing is displayed. At the same time, if I create queue programatically: It is listed and
Amazon SQS Long Polling not returning all messages
I have a requirement to read all messages in my Amazon SQS queue in 1 read and then sort it based on created timestamp and do business logic on it. To make sure all the SQS hosts are checked for messages, I enabled long polling. The way I did that was to set the default wait time for the queue