rabbitmq

package

v0.0.0-...-81dd437 Latest Latest Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

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 ¶

View Source

const (

	// SubjectAllChannels represents subject to subscribe for all the channels.
	SubjectAllChannels = "channels.#"
)

Variables ¶

This section is empty.

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.

Types ¶

This section is empty.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL