Add support for deferred publishing via Client (HTTP)

Author: seoester

nsq.go

@@ -6,6 +6,8 @@ import (
 	"io/ioutil"
 	"net/http"
 	"net/url"
+	"strconv"
+	"time"
 
 	"github.com/pkg/errors"
 )
@@ -28,6 +30,16 @@ func (c *Client) Publish(topic string, message []byte) (err error) {
 	return
 }
 
+func (c *Client) DeferredPublish(topic string, delay time.Duration, message []byte) (err error) {
+	delayStr := strconv.FormatUint(uint64(delay/time.Millisecond), 10)
+
+	_, err = c.do("POST", "/pub", url.Values{
+		"topic": []string{topic},
+		"defer": []string{delayStr},
+	}, message)
+	return
+}
+
 func (c *Client) MutliPublish(topic string, messages ...[]byte) (err error) {
 	_, err = c.do("POST", "/mpub", url.Values{
 		"topic": []string{topic},