GenerateQueueName is responsible to generate a unique queue for the connector to use It follows the naming schema OpenFaaS_[EXCHANGE_NAME]_[TOPIC].

NewBroker generates a new wrapper around the RabbitMQ Client lib.

NewConnectionManager creates a new instance using the provided dialer.

NewExchange creates a new exchange instance using the provided parameter.

NewFactory creates a new instance with no defaults set.

MaxAttempts of retries that will be performed.

Broker is a wrapper around the RabbitMQ Client lib, which allows better unit testing.

ConnectionManager is tasked with managing the connection Rabbit MQ.

Exchange contains all of the relevant units to handle communication with an exchange.

ExchangeFactory keeps tracks of all the build options provided to it during construction.

ChannelConsumer are interacting on channels.

ChannelCreator interface allows the generations of channels.

Connector is a high level interface for connection related methods.

ExchangeHandler offers a interface for the decleration of an exchange or the validation against existing exchanges on the RabbitMQ cluster.

ExchangeOrganizer combines the ability to start & stop exchanges.

Factory for building a Exchange.

Manager is a interface that combines the relevant methods to connect to Rabbit MQ And create a new channel on an existing connection.

QueueHandler offers a interface for the decleration & binding of an queues.

RabbitChannel is a abstraction of a RabbitMQ Channel.

RBConnection is a abstraction of a RabbitMQ Connection.

RBDialer is a abstraction of the RabbitMQ Dial methods.

Starter defines something that can be started.

Stopper defines something that can be stopped.