queue

Documentation

Index

• func New(connStr string, queueName string, logger *zap.Logger) (*client, error)
• type Message
• type Queue

Functions

func New

func New(connStr string, queueName string, logger *zap.Logger) (*client, error)

New creates a connection to a RMQ instance and configures the necessary queues

Types

type Message

type Message struct {
	ID int `json:"id"`
}

Message represents the structure of the messages being sent

type Queue

type Queue interface {
	Publish(msg *Message) error
	Consume(ctx context.Context) (<-chan *Message, error)
}

Queue is a interface to expose methods to interact with a queue