msgqueue

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

type MessageQueueInterface interface {
	Enq(msg []byte) error
	Deq(ctx context.Context) ([]byte, error)
	Len() int
	Clear() error
	IsLive() bool
	Renew()
	Destroy()
}