rmq_consumer

Documentation

Index

• Variables

Variables

var Env = []templates.Environment{
	{Name: "ConsumerAddress", Type: "string", Env: "CONSUMER_ADDR", Default: "amqp://guest:guest@localhost:5672"},
	{Name: "ConsumerExchange", Type: "string", Env: "CONSUMER_EXCHANGE"},
	{Name: "ConsumerQueue", Type: "string", Env: "CONSUMER_QUEUE"},
	{Name: "ConsumerRoutingKey", Type: "string", Env: "CONSUMER_ROUTING_KEY"},
}

var Libs = []templates.Library{
	{Name: "errors"},
	{Name: "github.com/streadway/amqp"},
}

var Models = map[string]string{
	"RabbitMq": `
type RabbitMq struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
	Queue      *amqp.Queue
}`,
}

var Props = []templates.Property{
	{Name: "Consumer", Type: "*RabbitMq", Default: "new(RabbitMq)"},
}

var TemplateRunFunction = `` /* 208-byte string literal not displayed */

var TemplateSetter = `` /* 260-byte string literal not displayed */

var TemplateSetterFunction = `` /* 860-byte string literal not displayed */

var Templates = map[string]string{
	"app/consumer.go": `package app

import (
	"go.uber.org/zap"
	"github.com/streadway/amqp"
)

func (a *Application) RunConsumer(consumer *RabbitMq, queue string) (err error) {
	a.Logger.Info("consumer start")
	msgs, err := consumer.Channel.Consume(
		queue,
		"{{.Name}}-consumer",
		false,
		false,
		false,
		false,
		nil,
	)
	if err != nil {
		return err
	}

	go func() {
		defer func() {
			consumer.Connection.Close()
		}()
		for {
			select {
			case msg := <-msgs:
				a.Logger.Debug("income message", zap.ByteString("message", msg.Body))
				if len(msg.Body) > 0 {
					go a.consumerHandle(&msg)
				}
			}
		}
	}()

	return nil
}

func (a *Application) consumerHandle(msg *amqp.Delivery) {
	//TODO: Implement me
	msg.Ack(false)
}
`,
}