rabbitmqutil

Documentation

Index

• func GetRabbitmqConn(rabbitmqManager RabbitmqManager) (*amqp.ConnectionWrapper, error)
• func ToRabbitmqConfig(cfg *configpb.Rabbitmq) *rabbitmqpkg.Config
• type RabbitmqManager
  • func NewRabbitmqManager(conf *configpb.Rabbitmq, loggerManager loggerutil.LoggerManager) (RabbitmqManager, error)
  • func NewSingletonRabbitmqManager(conf *configpb.Rabbitmq, loggerManager loggerutil.LoggerManager) (RabbitmqManager, error)

Functions

func GetRabbitmqConn

func GetRabbitmqConn(rabbitmqManager RabbitmqManager) (*amqp.ConnectionWrapper, error)

func ToRabbitmqConfig

func ToRabbitmqConfig(cfg *configpb.Rabbitmq) *rabbitmqpkg.Config

ToRabbitmqConfig ...

Types

type RabbitmqManager

type RabbitmqManager interface {
	Enable() bool
	GetClient() (*amqp.ConnectionWrapper, error)
	Close() error
}

func NewRabbitmqManager

func NewRabbitmqManager(conf *configpb.Rabbitmq, loggerManager loggerutil.LoggerManager) (RabbitmqManager, error)

func NewSingletonRabbitmqManager

func NewSingletonRabbitmqManager(conf *configpb.Rabbitmq, loggerManager loggerutil.LoggerManager) (RabbitmqManager, error)