package
Version:
v0.1.9
Opens a new window with list of versions in this module.
Published: Feb 8, 2023
License: Apache-2.0
Opens a new window with license information.
Imports: 9
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
NewConsumer sets up watermill subscriber and returns our consumer
Start reads messages from subscriber and processes them with passed in function.
eg: for msg := range messages {
fmt.Printf("received message: %s, payload: %s", msg.UUID, string(msg.Payload))
msg.Ack() }
Source Files
¶
Click to show internal directories.
Click to hide internal directories.