rfleming71 / junglebus Goto Github PK

Currently the code is hard coded to 5 retries per message and uses the default retry interval of 30 seconds. Both of these settings need to have support for configuration.

When the bus returns 0 messages, we should delay for a given amount of time before checking again. Right now the long polling returns every 14 seconds. This should reduce the number of empty sqs hits.

To make debugging easier, add the IP address of the message to the message attributes.

The SqsQueue is configured to receive up to 10 messages at a time. This can cause issues with the visibility timeout for the messages. If the first few messages take longer than the timeout, the later messages will re-enter the queue and be double processed.
For now the easy solution to to change the max receive to 1.

Notice some doc comments + exception messages in /JungleBus/Configuration/ReceiveConfigurationExtensions.cs that don't match the methods. Its trivial changes - I've attached some suggested changes in the attached zip.

Most of the change is for method SetNumberOfPollingInstances

ReceiveConfigurationExtensions.zip

The queuing portion of the bus has been forked off into the JungleQueue project. JungleBus should be updated to rely on the JungleQueue package.

Currently both the input queue and dead letter queue are hard coded to have a message retention period of 14 days. This should be split out into settings that can be configured.