Versions in this module Expand all Collapse all v0 v0.2.1 Aug 22, 2022 v0.2.0 Aug 22, 2022 v0.1.0 Jul 7, 2022 Changes in this version + func NewApp(basename string) *app.App + func Run(cfg *config.Config) error + type Consumer struct + func (c *Consumer) HandleMessage(m *nsq.Message) error + func (c *Consumer) Run(msgChan chan<- *message.Message) + func (c *Consumer) Stop()
Go to main page