subscriber

package

v0.0.0-...-d1e270b Latest Latest Go to latest Published: Jul 14, 2024 License: MIT Imports: 3 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type Subscriber struct {
	Log     *logger.Logger
	Channel *amqp.Channel
	Queue   *amqp.Queue
}

Subscriber defines the subscriber object

func NewSubscriber(log *logger.Logger, channel *amqp.Channel, queue *amqp.Queue) *Subscriber

NewSubscriber creates a new publisher

func (sub *Subscriber) BuildMessageQueue() (<-chan amqp.Delivery, error)

BuildMessageQueue builds consumable messages