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
Constants ¶
This section is empty.
Variables ¶
View Source
var RabbitChannelGlobal *amqp.Channel
View Source
var RabbitConnectionGlobal *amqp.Connection
View Source
var WorkerPool chan []byte
Functions ¶
func ConnectToRabbit ¶
func ConnectToRabbit() *amqp.Connection
func CreateChannel ¶
func CreateChannel(connection *amqp.Connection) *amqp.Channel
func DeclareQueue ¶
func FailOnError ¶
func InitPublishers ¶
func InitPublishers(workers int)
func PublishToRabbitMQ ¶
func PublishToRabbitMQ(log []byte)
func StartPublisher ¶
func StartPublisher()
func StartPublisherWorker ¶
func StartPublisherWorker()
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.