workers

Documentation

Overview

This Source Code Form is subject to the terms of the Mozilla Public License, v. 2.0. If a copy of the MPL was not distributed with this file, You can obtain one at http://mozilla.org/MPL/2.0/.

Contributor: Julien Vehent jvehent@mozilla.com [:ulfr]

Index

• func InitMQ(conf MqConf) (amqpChan *amqp.Channel, err error)
• func InitMqWithConsumer(conf MqConf, name, key string) (consumer <-chan amqp.Delivery, err error)
• type MqConf

Functions

func InitMQ

func InitMQ(conf MqConf) (amqpChan *amqp.Channel, err error)

func InitMqWithConsumer

func InitMqWithConsumer(conf MqConf, name, key string) (consumer <-chan amqp.Delivery, err error)

Types

type MqConf

type MqConf struct {
	Host, User, Pass, Vhost string
	Port                    int
	UseTLS                  bool
	TLScert, TLSkey, CAcert string
	Timeout                 string
}