code: func SelectBufferedQueue(redisHost, redisPort, redisPassword string, redisDB int64, name string, bufferSize int) (queue *BufferedQueue, err error) {
  	q, err := SelectQueue(redisHost, redisPort, redisPassword, redisDB, name)
  	if err != nil {
  		return nil, err
  	}
  
  	return &BufferedQueue{
  		Queue:        q,
  		BufferSize:   bufferSize,
  		Buffer:       make(chan *Package, bufferSize*2),
  		flushStatus:  make(chan chan bool, 1),
  		flushCommand: make(chan bool, bufferSize*2),
  	}, nil
  }
docs: // SelectBufferedQueue returns a BufferedQueue if a queue with the name exists