add support for the WORKING command

disque.go

@@ -227,6 +227,17 @@ func (pool *Pool) Nack(job *Job) error {
 	return nil
 }
 
+// Working on a job.
+func (pool *Pool) Working(job *Job) error {
+	sess := pool.redis.Get()
+	defer sess.Close()
+
+	if _, err := sess.Do("WORKING", job.ID); err != nil {
+		return err
+	}
+	return nil
+}
+
 // Wait blocks until the given job is ACKed.
 // Native WAITJOB discussed upstream at https://github.com/antirez/disque/issues/168.
 func (pool *Pool) Wait(job *Job) error {