# README
messageprocessor - An abstraction for consuming aws Kinesis messages
Contributing
License
This project is licensed under Apache 2.0. See LICENSE.txt for details.
Contributing Agreement
Atlassian requires signing a contributor's agreement before we can accept a patch. If you are an individual you can fill out the individual CLA. If you are contributing on behalf of your company then please fill out the corporate CLA.
# Functions
NewComponent populates default values.
NewMockMessageProcessor creates a new mock instance.
NewMockMessageProcessorError creates a new mock instance.
# Structs
MaxRetriesExceededError implements MessageProcessorError and is used to indicate to upstream application/ decorators that retries have been attempted and exhausted.
MockMessageProcessor is a mock of MessageProcessor interface.
MockMessageProcessorError is a mock of MessageProcessorError interface.
MockMessageProcessorErrorMockRecorder is the mock recorder for MockMessageProcessorError.
MockMessageProcessorMockRecorder is the mock recorder for MockMessageProcessor.
RetryableMessageProcessor is a `MessageProcessor` decorator that re-attempts processing of messages 'maxAttempts' number of times in case of failures 'maxAttempts' is a configurable parameter which can be set by consumer of this lib Exponential backoff has been implemented as a retry mechanism.
RetryableMessageProcessorComponent implements the settings.Component interface.
RetryableMessageProcessorConfig is the config for creating a RetryableMessageProcessor.
# Interfaces
MessageProcessor processes a consumed message.
MessageProcessorError represents an error that can be used to indicate to the consumer that an error should be retried.