rmq_publisher

Documentation

Index

• Variables

Variables

var Env = []templates.Environment{
	{Name: "PublisherAddress", Type: "string", Env: "PUBLISHER_ADDR", Default: "amqp://guest:guest@localhost:5672"},
	{Name: "PublisherExchange", Type: "string", Env: "PUBLISHER_EXCHANGE"},
	{Name: "PublisherRoutingKey", Type: "string", Env: "PUBLISHER_ROUTING_KEY"},
}

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

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

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

var TemplateRunFunction = ""

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

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

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

import (
	"github.com/streadway/amqp"
)

func (a *Application) publish(body []byte) error {
	return a.Publisher.Channel.Publish(
		a.Config.PublisherExchange,   // publish to an exchange
		a.Config.PublisherRoutingKey, // routing to 0 or more queues
		false,                        // mandatory
		false,                        // immediate
		amqp.Publishing{
			Headers:         amqp.Table{},
			ContentType:     "text/plain",
			ContentEncoding: "",
			Body:            body,
			DeliveryMode:    amqp.Persistent, // 1=non-persistent, 2=persistent
			Priority:        0,               // 0-9
			// a bunch of application/implementation-specific fields
		},
	)
}
`,
}