rabbitmq

Documentation

Index

• func NewConsumer(cfg *RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, ...) *consumer
• func NewPublisher(cfg *RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, ...) *publisher
• func NewRabbitMQConn(cfg *RabbitMQConfig) (*amqp.Connection, error, func())
• type IConsumer
• type IPublisher
• type RabbitMQConfig

Functions

func NewConsumer

func NewConsumer(cfg *RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, jaegerTracer trace.Tracer, handler func(queue string, msg amqp.Delivery) error) *consumer

func NewPublisher

func NewPublisher(cfg *RabbitMQConfig, conn *amqp.Connection, log logger.ILogger, jaegerTracer trace.Tracer) *publisher

func NewRabbitMQConn

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

Initialize new channel for rabbitmq

Types

type IConsumer

type IConsumer interface {
	ConsumeMessage(ctx context.Context, msg interface{}) error
}

type IPublisher

type IPublisher interface {
	PublishMessage(ctx context.Context, msg interface{}) error
}

type RabbitMQConfig

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