Subscribe feature support for dequeue

[jhunters]

Demostration as follow:

err := queue.Subscribe(func (index int64, data []byte, err error) { // handle data }) if err != nil { // warning the error }