v0.11.0ateam

Fix for errors when spooling to disk

--- a/destination/spool.go
+++ b/destination/spool.go
@@ -45,7 +45,7 @@ func NewSpool(key, spoolDir string, bufSize int, maxBytesPerFile, syncEvery int6
        queue := nsqd.NewDiskQueue(dqName, spoolDir, maxBytesPerFile, syncEvery, syncPeriod).(*nsqd.DiskQueue)
        s := Spool{
                key:             key,
-               InRT:            make(chan []byte, 10),
+               InRT:            make(chan []byte, 4096),
                InBulk:          make(chan []byte),
                Out:             NewSlowChan(queue.ReadChan(), unspoolSleep),
                spoolSleep:      spoolSleep,