egommerce/catalog-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

CQ fix
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Piotr Biernat 2022-11-29 23:32:59 +01:00
parent 27b1f1fb35
commit 49671344df
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/cmd/worker/main.go
View File

@ -105,7 +105,7 @@ func main() {
for d := range msgs { for d := range msgs {
msg, err := amqp.Deserialize(d.Body) msg, err := amqp.Deserialize(d.Body)
if err != nil { if err != nil {
logger.Log("json error:", err) logger.Log("json error: %v\n", err)
d.Reject(false) // FIXME: how to handle erros in queue...???? d.Reject(false) // FIXME: how to handle erros in queue...????
continue continue
} }