code: func CreateBufferedQueue(redisHost, redisPort, redisPassword string, redisDB int64, name string, bufferSize int) *BufferedQueue {
  	q := CreateQueue(redisHost, redisPort, redisPassword, redisDB, name)
  	return &BufferedQueue{
  		Queue:        q,
  		BufferSize:   bufferSize,
  		Buffer:       make(chan *Package, bufferSize*2),
  		flushStatus:  make(chan chan bool, 1),
  		flushCommand: make(chan bool, bufferSize*2),
  	}
  }
docs: // CreateBufferedQueue returns BufferedQueue.
  // To start writing the buffer to redis use Start().
  // Optimal BufferSize seems to be around 200.
  // Works like SelectBufferedQueue for existing queues