diff --git a/job.go b/job.go index dde57ce..9b1c2c1 100644 --- a/job.go +++ b/job.go @@ -19,7 +19,8 @@ import ( ) func createJob(jobTypeID64 int64, priority int32, userID64 int64, trigger int64, schedule time.Time, payload []byte) (int64, error) { - zb := new(bytes.Buffer) + var zb bytes.Buffer + zw := zlib.NewWriter(&zb) zw.Write(payload) zw.Close()