![dummy_backend_queue.go dummy_backend_queue.go](https://image.shishitao.com:8440/aHR0cHM6Ly9ia3FzaW1nLmlrYWZhbi5jb20vdXBsb2FkL2NoYXRncHQtcy5wbmc%2FIQ%3D%3D.png?!?w=700&webp=1)
package nsqd
type dummyBackendQueue struct {
readChan chan []byte
}
func newDummyBackendQueue() BackendQueue {
return &dummyBackendQueue{readChan: make(chan []byte)}
}
func (d *dummyBackendQueue) Put([]byte) error {
return nil
}
func (d *dummyBackendQueue) ReadChan() chan []byte {
return d.readChan
}
func (d *dummyBackendQueue) Close() error {
return nil
}
func (d *dummyBackendQueue) Delete() error {
return nil
}
func (d *dummyBackendQueue) Depth() int64 {
return int64(0)
}
func (d *dummyBackendQueue) Empty() error {
return nil
}