@@ -131,11 +131,9 @@ func main() {
131
131
132
132
// initial queue pool
133
133
q := queue.NewPool (5 , queue.WithFn (func (ctx context.Context , m core.TaskMessage ) error {
134
- v , ok := m.(*job)
135
- if !ok {
136
- if err := json.Unmarshal (m.Payload (), &v); err != nil {
137
- return err
138
- }
134
+ var v job
135
+ if err := json.Unmarshal (m.Payload (), &v); err != nil {
136
+ return err
139
137
}
140
138
141
139
rets <- " Hi, " + v.Name + " , " + v.Message
@@ -208,11 +206,9 @@ func main() {
208
206
// concurrent job number
209
207
nsq.WithMaxInFlight (10 ),
210
208
nsq.WithRunFunc (func (ctx context.Context , m core.TaskMessage ) error {
211
- v , ok := m.(*job)
212
- if !ok {
213
- if err := json.Unmarshal (m.Payload (), &v); err != nil {
214
- return err
215
- }
209
+ var v job
210
+ if err := json.Unmarshal (m.Payload (), &v); err != nil {
211
+ return err
216
212
}
217
213
218
214
rets <- v.Message
@@ -287,11 +283,9 @@ func main() {
287
283
nats.WithSubj (" example" ),
288
284
nats.WithQueue (" foobar" ),
289
285
nats.WithRunFunc (func (ctx context.Context , m core.TaskMessage ) error {
290
- v , ok := m.(*job)
291
- if !ok {
292
- if err := json.Unmarshal (m.Payload (), &v); err != nil {
293
- return err
294
- }
286
+ var v job
287
+ if err := json.Unmarshal (m.Payload (), &v); err != nil {
288
+ return err
295
289
}
296
290
297
291
rets <- v.Message
@@ -371,11 +365,9 @@ func main() {
371
365
redisdb.WithAddr (" 127.0.0.1:6379" ),
372
366
redisdb.WithChannel (" foobar" ),
373
367
redisdb.WithRunFunc (func (ctx context.Context , m core.TaskMessage ) error {
374
- v , ok := m.(*job)
375
- if !ok {
376
- if err := json.Unmarshal (m.Payload (), &v); err != nil {
377
- return err
378
- }
368
+ var v job
369
+ if err := json.Unmarshal (m.Payload (), &v); err != nil {
370
+ return err
379
371
}
380
372
381
373
rets <- v.Message
0 commit comments