egommerce/basket-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-30 02:11:23 +01:00
parent 19e44b60f0
commit 2fcd542194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -111,7 +111,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", err)
d.Reject(false) // FIXME: how to handle erros in queue...???? d.Reject(false) // FIXME: how to handle erros in queue...????
continue continue
} }
@ -128,10 +128,10 @@ func main() {
// FIXME CHECK if basket exists // FIXME CHECK if basket exists
_, err := basket.Get(basketID) _, err := basket.Get(basketID)
if err != nil { if err != nil {
logger.Log("Basket#%s not found. Creating...", basketID) logger.Log("Basket#:%s not found. Creating...", basketID)
err := basket.Create(basketID) err := basket.Create(basketID)
if err != nil { if err != nil {
logger.Log("Creating basket error: %s", err) logger.Log("Creating basket error: %v", err)
d.Reject(false) d.Reject(false)
continue continue
} }