babex

Documentation

Index

• Variables

Variables

var Env = []templates.Environment{
	{Name: "BabexAddr", Type: "string", Env: "BABEX_ADDR", Default: "amqp://guest:guest@localhost:5672/"},
	{Name: "BabexExchange", Type: "string", Env: "BABEX_EXCHANGE"},
	{Name: "BabexName", Type: "string", Env: "BABEX_NAME"},
}

var Libs = []templates.Library{
	{Name: "github.com/matroskin13/babex"},
}

var Models = map[string]string{}

var Props = []templates.Property{
	{Name: "Service", Type: "*babex.Service"},
}

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

var TemplateSetter = `
	if err = app.setBabex(); err != nil {
		logger.Fatal("cannot create Babex node", zap.Error(err))
		return nil, err
	}`

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

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

import (
	"github.com/matroskin13/babex"
	"go.uber.org/zap"
)

func (a *Application) RunBabex() error {
	msgs, err := a.Service.GetMessages()
	if err != nil {
		a.Logger.Fatal("cannot get messages", zap.Error(err))
		return err
	}
	errs := a.Service.GetErrors()
	a.Logger.Info("service listen queue")

	go func() {
		for {
			select {
			case msg := <-msgs:
				err := a.receive(msg)
				if err != nil {
					a.Logger.Error("error on processing message", zap.Error(err))
				}
			case err := <-errs:
				a.Error <- err
			}
		}
	}()
	return nil
}

func (a *Application) receive(msg *babex.Message) (err error) {
	//region Implementation
	//TODO: Implement me
	//endregion
	//region Next
	err = a.Service.Next(msg, msg.Data, nil)
	if err != nil && err != babex.ErrorNextIsNotDefined {
		a.Logger.Error("cannot next", zap.Error(err))
		return err
	}
	//endregion
	return nil
}
`,
}