dummy_backend_queue.go (nsq-1.2.0) | : | dummy_backend_queue.go (nsq-1.2.1) | ||
---|---|---|---|---|
skipping to change at line 15 | skipping to change at line 15 | |||
} | } | |||
func newDummyBackendQueue() BackendQueue { | func newDummyBackendQueue() BackendQueue { | |||
return &dummyBackendQueue{readChan: make(chan []byte)} | return &dummyBackendQueue{readChan: make(chan []byte)} | |||
} | } | |||
func (d *dummyBackendQueue) Put([]byte) error { | func (d *dummyBackendQueue) Put([]byte) error { | |||
return nil | return nil | |||
} | } | |||
func (d *dummyBackendQueue) ReadChan() chan []byte { | func (d *dummyBackendQueue) ReadChan() <-chan []byte { | |||
return d.readChan | return d.readChan | |||
} | } | |||
func (d *dummyBackendQueue) Close() error { | func (d *dummyBackendQueue) Close() error { | |||
return nil | return nil | |||
} | } | |||
func (d *dummyBackendQueue) Delete() error { | func (d *dummyBackendQueue) Delete() error { | |||
return nil | return nil | |||
} | } | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 1 lines changed or added |