Struct queue

queue/queue.go:68–78

}

type queue struct {
	chanSubs  map[string]*chanSub
	mu        sync.Mutex
	done      chan struct{}
	interrupt chan struct{}
	callback  chan *Message
	isClose   int32
	name      string
	cfg       *types.Chain33Config
	msgPool   *sync.Pool
}

// New new queue struct
func New(name string) Queue {