mq

Documentation

Index

• type Amqp
  • 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

Types

type Amqp

type Amqp struct {
	emission.Emitter
	// contains filtered or unexported fields
}

func New

func New(id, url string) *Amqp

func (*Amqp) BroadCast

func (a *Amqp) BroadCast(msg map[string]interface{}) error

func (*Amqp) Close

func (a *Amqp) Close()

func (*Amqp) ConsumeBroadcast

func (a *Amqp) ConsumeBroadcast() (<-chan amqp.Delivery, error)

func (*Amqp) ConsumeRPC

func (a *Amqp) ConsumeRPC() (<-chan amqp.Delivery, error)

func (*Amqp) RpcCall

func (a *Amqp) RpcCall(id string, msg map[string]interface{}, corrID string) (string, error)

func (*Amqp) RpcCallWithResp

func (a *Amqp) RpcCallWithResp(id string, msg map[string]interface{}, callback interface{}) error