rabbit

Documentation

Index

• Variables
• func ConnectToRabbit() *amqp.Connection
• func CreateChannel(connection *amqp.Connection) *amqp.Channel
• func DeclareQueue(RabbitChannel *amqp.Channel) error
• func FailOnError(err error, msg string) error
• func Host() string
• func InitPublishers(workers int)
• func Port() string
• func PublishToRabbitMQ(log []byte)
• func Pwd() string
• func Queue() string
• func RabbitMQConnectionReconnectHandle(RabbitConnection *amqp.Connection, RabbitChannel *amqp.Channel, ...)
• func RabbitMQCreateConnection(RabbitConnection *amqp.Connection, RabbitChannel *amqp.Channel, ...) (*amqp.Connection, *amqp.Channel, chan *amqp.Error)
• func StartPublisher()
• func StartPublisherWorker()
• func User() string
• func WorkerPublishToRabbitMQ(RabbitChannel *amqp.Channel, log []byte) error

Variables

var RabbitChannelGlobal *amqp.Channel

var RabbitConnectionGlobal *amqp.Connection

var WorkerPool chan []byte

Functions

func ConnectToRabbit

func ConnectToRabbit() *amqp.Connection

func CreateChannel

func CreateChannel(connection *amqp.Connection) *amqp.Channel

func DeclareQueue

func DeclareQueue(RabbitChannel *amqp.Channel) error

func FailOnError

func FailOnError(err error, msg string) error

func Host

func Host() string

func InitPublishers

func InitPublishers(workers int)

func Port

func Port() string

func PublishToRabbitMQ

func PublishToRabbitMQ(log []byte)

func Pwd

func Pwd() string

func Queue

func Queue() string

func RabbitMQConnectionReconnectHandle

func RabbitMQConnectionReconnectHandle(RabbitConnection *amqp.Connection, RabbitChannel *amqp.Channel, RabbitCloseError chan *amqp.Error)

func RabbitMQCreateConnection

func RabbitMQCreateConnection(RabbitConnection *amqp.Connection, RabbitChannel *amqp.Channel, RabbitCloseError chan *amqp.Error) (*amqp.Connection, *amqp.Channel, chan *amqp.Error)

func StartPublisher

func StartPublisher()

func StartPublisherWorker

func StartPublisherWorker()

func User

func User() string

func WorkerPublishToRabbitMQ

func WorkerPublishToRabbitMQ(RabbitChannel *amqp.Channel, log []byte) error