rabbit

Documentation

Index

• type Consumer
  • func NewRabbitConsumer(logger *zap.Logger, cfg configuration.RabbitConfig, routingKey string) (Consumer, error)
• type ConsumerImpl
  • func (c *ConsumerImpl) Close() error
  • func (c *ConsumerImpl) Run(handler rabbitmq.Handler) error
• type ConsumerMock
  • func (m *ConsumerMock) Close() error
  • func (m *ConsumerMock) Run(handler rabbitmq.Handler) error
• type Publisher
  • func NewRabbitPublisher(logger *zap.Logger, cfg configuration.RabbitConfig) (Publisher, error)
• type PublisherImpl
  • func (p *PublisherImpl) Close() error
  • func (p *PublisherImpl) Publish(msg []byte, routingKey string, withExpiration bool) error
• type PublisherMock
  • func (m *PublisherMock) Close() error
  • func (m *PublisherMock) Publish(msg []byte, routingKey string, withExpiration bool) error

Types

type Consumer

type Consumer interface {
	Close() error
	Run(handler rabbitmq.Handler) error
}

func NewRabbitConsumer

func NewRabbitConsumer(logger *zap.Logger, cfg configuration.RabbitConfig, routingKey string) (Consumer, error)

type ConsumerImpl

type ConsumerImpl struct {
	Conn     *rabbitmq.Conn
	Consumer *rabbitmq.Consumer
}

func (*ConsumerImpl) Close

func (c *ConsumerImpl) Close() error

func (*ConsumerImpl) Run

func (c *ConsumerImpl) Run(handler rabbitmq.Handler) error

type ConsumerMock

type ConsumerMock struct {
	Logger *zap.Logger
}

func (*ConsumerMock) Close

func (m *ConsumerMock) Close() error

func (*ConsumerMock) Run

func (m *ConsumerMock) Run(handler rabbitmq.Handler) error

type Publisher

type Publisher interface {
	Publish(msg []byte, routingKey string, withExpiration bool) error
	Close() error
}

func NewRabbitPublisher

func NewRabbitPublisher(logger *zap.Logger, cfg configuration.RabbitConfig) (Publisher, error)

type PublisherImpl

type PublisherImpl struct {
	Conn         *rabbitmq.Conn
	Publisher    *rabbitmq.Publisher
	ExchangeName string
}

func (*PublisherImpl) Close

func (p *PublisherImpl) Close() error

func (*PublisherImpl) Publish

func (p *PublisherImpl) Publish(msg []byte, routingKey string, withExpiration bool) error

type PublisherMock

type PublisherMock struct {
	Logger *zap.Logger
}

func (*PublisherMock) Close

func (m *PublisherMock) Close() error

func (*PublisherMock) Publish

func (m *PublisherMock) Publish(msg []byte, routingKey string, withExpiration bool) error