consumer

Documentation

Index

• type OtpRabbitMQ
  • func NewOtpRabbitMQ(oh *handler.OtpRabbitMQ) *OtpRabbitMQ
  • func (o *OtpRabbitMQ) Close()
  • func (o *OtpRabbitMQ) Consume(ctx context.Context)

Types

type OtpRabbitMQ

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

func NewOtpRabbitMQ

func NewOtpRabbitMQ(oh *handler.OtpRabbitMQ) *OtpRabbitMQ

func (*OtpRabbitMQ) Close

func (o *OtpRabbitMQ) Close()

func (*OtpRabbitMQ) Consume

func (o *OtpRabbitMQ) Consume(ctx context.Context)