broker

Documentation

Index

• type Consumer
  • func NewConsumer(db *sql.DB, conn *amqp.Connection) (Consumer, error)
  • func (consumer *Consumer) Consume(topics []string) error

Types

type Consumer

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

func NewConsumer

func NewConsumer(
	db *sql.DB,
	conn *amqp.Connection,
) (Consumer, error)

func (*Consumer) Consume

func (consumer *Consumer) Consume(topics []string) error