Versions in this module Expand all Collapse all v1 v1.0.0 Apr 4, 2019 Changes in this version + func BasicJSONPublishing(data interface{}) (p amqp.Publishing, err error) + type Publisher struct + Config *amqpconfig.Config + func NewPublisher(config *amqpconfig.Config) (p Publisher, err error) + func (p *Publisher) Close() error + func (p *Publisher) IsUp() bool + func (p *Publisher) Publish(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error + func (p *Publisher) PublishExchange(eName string, mandatory, immediate bool, msg amqp.Publishing) error + func (p *Publisher) PublishKey(key string, mandatory, immediate bool, msg amqp.Publishing) error
Go to main page