gg_mq

README

Message Queue

Message Queue implementation that support drivers for:

• AMQP: RabbitMQ client (github.com/streadway/amqp)

Documentation

Index

• type MQHelper
  • func (instance *MQHelper) Build(config interface{}) (mq_commons.IDriver, error)

Types

type MQHelper

type MQHelper struct {
}

var MQ *MQHelper

func (*MQHelper) Build

func (instance *MQHelper) Build(config interface{}) (mq_commons.IDriver, error)

Build return a client implementation if supported config: ex {"protocol":"amqp","secret":"1234","url":"amqp://test:test@localhost:5672/"}