We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b64c331 commit 5461ddbCopy full SHA for 5461ddb
README.md
@@ -64,11 +64,9 @@ func main() {
64
redisdb.WithAddr("127.0.0.1:6379"),
65
redisdb.WithChannel("foobar"),
66
redisdb.WithRunFunc(func(ctx context.Context, m queue.TaskMessage) error {
67
- v, ok := m.(*job)
68
- if !ok {
69
- if err := json.Unmarshal(m.Bytes(), &v); err != nil {
70
- return err
71
- }
+ var v job
+ if err := json.Unmarshal(m.Payload(), &v); err != nil {
+ return err
72
}
73
74
rets <- v.Message
0 commit comments