NewMessageSource returns a new insurance asynchronous message source, given an AsyncMessageSource.

WithSourceAckBufferSize sets the ack channel buffer size.

WithSourceConsumers sets the number of concurrent source consumers.

WithSourceMsgBufferSize sets the msg channel buffer size.

MessageSource represents a message source that allows async consumption and relieves the consumer from having to deal with acknowledgements using channels.

AckFunc is a function to call to send acknowledgement that a message was received.

ConsumerMessageHandler is the callback function type that async message consumers must implement.

MessageSourceOption is a function which sets a MessageSource configuration option.