package
0.16.0
Repository: https://github.com/absmach/supermq.git
Documentation: pkg.go.dev

# README

Messaging

messaging package defines Publisher, Subscriber and an aggregate Pubsub interface.

Subscriber interface defines methods used to subscribe to a message broker such as MQTT or NATS or RabbitMQ.

Publisher interface defines methods used to publish messages to a message broker such as MQTT or NATS or RabbitMQ.

Pubsub interface is composed of Publisher and Subscriber interface and can be used to send messages to as well as to receive messages from a message broker.

# Packages

No description provided by the author
No description provided by the author
No description provided by the author
Package mqtt hold the implementation of the Publisher and PubSub interfaces for the MQTT messaging system, the internal messaging broker of the SuperMQ IoT platform.
Package nats hold the implementation of the Publisher and PubSub interfaces for the NATS messaging system, the internal messaging broker of the SuperMQ IoT platform.
Package rabbitmq holds the implementation of the Publisher and PubSub interfaces for the RabbitMQ messaging system, the internal messaging broker of the SuperMQ IoT platform.
Copyright (c) Abstract Machines SPDX-License-Identifier: Apache-2.0.

# Constants

DeliverAllPolicy starts delivering messages from the very beginning of a stream.
DeliverNewPolicy will only deliver new messages that are sent after the consumer is created.

# Variables

No description provided by the author

# Structs

Message represents a message emitted by the SuperMQ adapters layer.
No description provided by the author

# Interfaces

MessageHandler represents Message handler for Subscriber.
Publisher specifies message publishing API.
PubSub represents aggregation interface for publisher and subscriber.
Subscriber specifies message subscription API.

# Type aliases

No description provided by the author
Option represents optional configuration for message broker.