Redrive Policy Example

Hi @adamw ,

If you have any samples to create redrivepolicy links using dead queues that would be great . Currently , I am trying to create a redrivepolicy during CreateQueueRequest (Amazon Java SDK) using queue attributes. I do get a debug point on the RedrivePolicy.class in the elasticmq package . But elasticmq doesnt seem to create a link with the DeadLetterQueue.

My java code :

final Map<String, String> deadLetterQueueAttrs = new HashMap<>();
deadLetterQueueAttrs.put("VisibilityTimeout", "600");
final CreateQueueRequest createDeadLetterQueueRequest = new CreateQueueRequest()
.withQueueName(queueName + "-error")
.withAttributes(deadLetterQueueAttrs);

	final CreateQueueResult deadLetterQueueResult = amazonSQSAsyncClient.createQueue(createDeadLetterQueueRequest);
	final GetQueueAttributesResult deadLetterQueueArnResult = amazonSQSAsyncClient.getQueueAttributes(deadLetterQueueResult.getQueueUrl(), Arrays.asList("QueueArn"));

	final Map<String, String> queueAttributes = new HashMap<>();
	final StringBuilder redrivePolicyParamBuilder = new StringBuilder()
		.append("{\"deadLetterTargetArn\" : \"")
		.append(deadLetterQueueArnResult.getAttributes().get("QueueArn"))
		.append("\",")
		.append("\"maxReceiveCount\": \"1\"}");
	queueAttributes.put("RedrivePolicy", redrivePolicyParamBuilder.toString());
	queueAttributes.put("VisibilityTimeout","600");

	final CreateQueueRequest createQueueRequest = new CreateQueueRequest()
		.withQueueName(queueName)
		.withAttributes(queueAttributes);

	final CreateQueueResult createQueueResult = amazonSQSAsyncClient.createQueue(createQueueRequest);

No errors are thrown but the redrive policy link is not created,

Kindly help.

Regards,
Harish

Start at RedrivePolicy.class and the CreateQueueRequest attribute handling described in the report, then reproduce the Java AWS SDK sequence that creates the dead-letter queue and the source queue. Confirm whether the RedrivePolicy link is stored and observable as expected, and add or update a focused test if the relevant test location can be identified.