rabbitmq

Documentation

Overview

Package rabbitmq holds the implementation of the Publisher and PubSub interfaces for the RabbitMQ messaging system, the internal messaging broker of the Mainflux IoT platform. Due to the practical requirements implementation Publisher is created alongside PubSub. The reason for this is that Subscriber implementation of RabbitMQ brings the burden of additional struct fields which are not used by Publisher. Subscriber is not implemented separately because PubSub can be used where Subscriber is needed.

Index

• Constants
• func NewPubSub(url, queue string, logger log.Logger) (messaging.PubSub, error)
• func NewPublisher(url string) (messaging.Publisher, error)

Constants

const (

	// SubjectAllProfiles represents subject to subscribe for all the profiles.
	SubjectAllProfiles = "profiles.#"
)

Functions

func NewPubSub

func NewPubSub(url, queue string, logger log.Logger) (messaging.PubSub, error)

NewPubSub returns RabbitMQ message publisher/subscriber.

func NewPublisher

func NewPublisher(url string) (messaging.Publisher, error)

NewPublisher returns RabbitMQ message Publisher.