start

fun start()(source)

Starts the message queue consumer by initializing and launching processes for notification, consumption, and fetching, if they are not already running.

  • The notification process is responsible for handling insertion notifications.

  • The consumption process manages message processing from the queue.

  • The fetching process retrieves messages from the queue for processing.

This method ensures that all required jobs (notify, consume, fetch) are properly started to maintain the functionality of the consumer.