Versions in this module Expand all Collapse all v0 v0.1.1 Mar 10, 2020 v0.1.0 Feb 22, 2020 Changes in this version + type Amqp struct + func New(id, url string) *Amqp + func (a *Amqp) BroadCast(msg map[string]interface{}) error + func (a *Amqp) Close() + func (a *Amqp) ConsumeBroadcast() (<-chan amqp.Delivery, error) + func (a *Amqp) ConsumeRPC() (<-chan amqp.Delivery, error) + func (a *Amqp) RpcCall(id string, msg map[string]interface{}, corrID string) (string, error) + func (a *Amqp) RpcCallWithResp(id string, msg map[string]interface{}, callback interface{}) error
Go to main page