Versions in this module Expand all Collapse all v0 v0.0.2 May 29, 2020 Changes in this version + func Bind(foreground bool) error type Configuration + Concurrency int v0.0.1 May 14, 2020 Changes in this version + var Channels map[string]chan string + var Handlers map[string]func(message amqp.Delivery) bool + func AsyncRPCCall(routingKey string, message []byte) + func Initialize(app string, rabbitmqHost string, rabbitmqUser string, rabbitmqPass string, ...) + func RPCCall(routingKey string, message []byte) string + func Start() + type Channel struct + Channel *amqp.Channel + func GetChannel(conn *Conn) (Channel, error) + func (conn Channel) Publish(routingKey string, replyTo string, data []byte) error + func (conn Channel) StartConsumer(concurrency int) error + type Configuration struct + App string + Rabbitmq Rabbitmq + Threads int + var Config Configuration + type Conn struct + Connection *amqp.Connection + var Connection Conn + func GetConn(rabbitURL string) (Conn, error) + type Rabbitmq struct + Exchange string + Host string + Password string + User string