Versions in this module Expand all Collapse all v0 v0.1.1 Feb 20, 2021 v0.1.0 Feb 20, 2021 Changes in this version + type Consumer struct + func NewConsumer(connection string) *Consumer + func (nc *Consumer) Consumer(topic string, channel string, thread int, handler func(message []byte) error) error + func (nc *Consumer) Stop() + type Producer struct + func NewProducer(connection string) *Producer + func (p *Producer) Publish(topic string, message []byte) error + func (p *Producer) Stop()
Go to main page