rabbitmq

Documentation

Index

• func NewRabbitMQConn(cfg *RabbitMQConfig, ctx context.Context) (*amqp.Connection, error)
• type Consumer
  • func (c Consumer[T]) ConsumeMessage(msg interface{}, dependencies T) error
  • func (c Consumer[T]) IsConsumed(msg interface{}) bool
• type IConsumer
  • func NewConsumer[T any](ctx context.Context, cfg *RabbitMQConfig, conn *amqp.Connection, ...) IConsumer[T]
• type IPublisher
  • func NewPublisher(ctx context.Context, cfg *RabbitMQConfig, conn *amqp.Connection, ...) IPublisher
• type Publisher
  • func (p Publisher) IsPublished(msg interface{}) bool
  • func (p Publisher) PublishMessage(msg interface{}) error
• type RabbitMQConfig

Functions

func NewRabbitMQConn

func NewRabbitMQConn(cfg *RabbitMQConfig, ctx context.Context) (*amqp.Connection, error)

Initialize new channel for rabbitmq

Types

type Consumer

type Consumer[T any] struct {
	// contains filtered or unexported fields
}

func (Consumer[T]) ConsumeMessage

func (c Consumer[T]) ConsumeMessage(msg interface{}, dependencies T) error

func (Consumer[T]) IsConsumed

func (c Consumer[T]) IsConsumed(msg interface{}) bool

type IConsumer

type IConsumer[T any] interface {
	ConsumeMessage(msg interface{}, dependencies T) error
	IsConsumed(msg interface{}) bool
}

func NewConsumer

func NewConsumer[T any](ctx context.Context, cfg *RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, jaegerTracer trace.Tracer, handler func(queue string, msg amqp.Delivery, dependencies T) error) IConsumer[T]

type IPublisher

type IPublisher interface {
	PublishMessage(msg interface{}) error
	IsPublished(msg interface{}) bool
}

func NewPublisher

func NewPublisher(ctx context.Context, cfg *RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, jaegerTracer trace.Tracer) IPublisher

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func (Publisher) IsPublished

func (p Publisher) IsPublished(msg interface{}) bool

func (Publisher) PublishMessage

func (p Publisher) PublishMessage(msg interface{}) error

type RabbitMQConfig

type RabbitMQConfig struct {
	Host         string
	Port         int
	User         string
	Password     string
	ExchangeName string
	Kind         string
}