mq

Documentation

Index

• type IMQ
• type Message

Types

type IMQ

type IMQ interface {
	GetMQSection() string
	InitMQ(config util.Config) error
	PublishMessage(c context.Context, msg string) error
	FetchMessage(c context.Context) Message
	Start()
}

type Message

type Message struct {
	C    context.Context
	Body string
	Ack  func() error
	Nack func() error
}