Task not written to data base.

[rodrabe]

I can publish and process a task using the example you providie.

When . I tried to publish using my application it appears not to be written to my DB.

This is the log entry I am seeing: logging/logging.go:129 Task published {"logger": "bokchoy", "component": "queue", "queue": {"name": "suspend", "consumers_count": 2}, "duration": "6.290392ms", "task": {"id": "01DV2D28B0MQJHBF4QX1EFD6Y3", "name": "suspend", "status": "waiting", "payload": "{crn:v1:staging:public:is:us-south-1:a/78d00cc88d254fba849cdd8a8e4f1618::instance:dc4b93ef-2c02-4e4b-bd4c-35deb6c39c6e}", "max_retries": 3, "ttl": "3m0s", "timeout": "3m0s", "published_at": "2019-12-02T04:14:30.240Z", "retry_intervals": "30s, 30s, 30s"}}

Doing a get with the task ID does not return anything.

[thoas]

[git:master] thoas belgariade ~/Sites/golang/src/github.com/thoas/bokchoy 
$ go run examples/main.go -run publish
2019-12-02T09:53:29.388+0100	DEBUG	logging/logging.go:129	Connecting to redis (client)...	{"logger": "bokchoy"}
2019-12-02T09:53:29.392+0100	DEBUG	logging/logging.go:129	Connected to redis (client)	{"logger": "bokchoy"}
2019-12-02T09:53:29.393+0100	DEBUG	logging/logging.go:129	Task published	{"logger": "bokchoy", "component": "queue", "queue": {"name": "tasks.message", "consumers_count": 0}, "duration": "190.909µs", "task": {"id": "01DV2X135G7S2J9XF57YDFH5EW", "name": "tasks.message", "status": "waiting", "payload": "{hello}", "max_retries": 3, "ttl": "3m0s", "timeout": "3m0s", "published_at": "2019-12-02T08:53:29.392Z", "retry_intervals": "1m0s, 2m0s, 3m0s"}}
2019/12/02 09:53:29 <Task name=tasks.message id=01DV2X135G7S2J9XF57YDFH5EW, status=waiting, published_at=2019-12-02 08:53:29.392948 +0000 UTC> published
[git:master] thoas belgariade ~/Sites/golang/src/github.com/thoas/bokchoy 
$ go run examples/main.go -run get -task-id 01DV2X135G7S2J9XF57YDFH5EW
2019-12-02T09:53:47.131+0100	DEBUG	logging/logging.go:129	Connecting to redis (client)...	{"logger": "bokchoy"}
2019-12-02T09:53:47.135+0100	DEBUG	logging/logging.go:129	Connected to redis (client)	{"logger": "bokchoy"}
2019-12-02T09:53:47.135+0100	DEBUG	logging/logging.go:129	Task retrieved	{"logger": "bokchoy", "component": "queue", "queue": {"name": "tasks.message", "consumers_count": 0}, "duration": "175.007µs", "task": {"id": "01DV2X135G7S2J9XF57YDFH5EW", "name": "tasks.message", "status": "waiting", "payload": "map[data:hello]", "max_retries": 3, "ttl": "3m0s", "timeout": "3m0s", "published_at": "2019-12-02T08:53:29.000Z", "retry_intervals": "1m0s, 2m0s, 3m0s"}}
2019/12/02 09:53:47 <Task name=tasks.message id=01DV2X135G7S2J9XF57YDFH5EW, status=waiting, published_at=2019-12-02 08:53:29 +0000 UTC> retrieved
[git:master] thoas belgariade ~/Sites/golang/src/github.com/thoas/bokchoy

You will need to provide more information, it does work properly with examples.

[rodrabe]

HI thanks,

This is the code; publishes fine, get and save work. My handler is not invoked or the total count is not incremented.

task, err := app.SuspendQueue.Publish(ctx, message1{Crn: i.resourceCrn.String()},
bokchoy.WithMaxRetries(3),
bokchoy.WithRetryIntervals([]time.Duration{
30 * time.Second, 30 * time.Second, 30 * time.Second}))

if err != nil {
	logger.WithError(err).Error("Error publishing suspend message.")
}
logger.Info("published suspend " + task.String())
err = app.SuspendQueue.Save(ctx, task)
if err != nil {
	logger.WithError(err).Error("Error saving suspend message.")
}
task, err = app.SuspendQueue.Get(ctx, task.ID)
if err != nil {
	logger.WithError(err).Error("Error getting suspend message.")
}
logger.Info("get suspend " + task.String())
qs, _ := app.SuspendQueue.Count(ctx)
riaaslogger.Get(nil).Info("TOTAL: " + strconv.Itoa(qs.Total))
app.SuspendQueue.HandleFunc(func(r *bokchoy.Request) error {

	riaaslogger.Get(nil).Info("Received suspend message 2")
	return nil
})
return err

This is the log:

Dec 2 08:44:11 vpc-service-broker-c7855fd67-2jwpr vpc-service-broker DEBUG logging/logging.go:129 Task published {"logger": "bokchoy", "component": "queue", "queue": {"name": "suspend", "consumers_count": 2}, "duration": "5.184552ms", "task": {"id": "01DV3H37RJMQJHBF4QX1EFD6Y3", "name": "suspend", "status": "waiting", "payload": "{crn:v1:staging:public:is:us-south-1:a/c1cf76af9e6046058d0f1b562eb0ca67::instance:7dbc41ab-0108-4ffb-9b30-79fd6666f74f}", "max_retries": 3, "ttl": "3m0s", "timeout": "3m0s", "published_at": "2019-12-02T14:44:11.154Z", "retry_intervals": "30s, 30s, 30s"}}
Dec 2 08:44:11 vpc-service-broker-c7855fd67-2jwpr vpc-service-broker info published suspend <Task name=suspend id=01DV3H37RJMQJHBF4QX1EFD6Y3, status=waiting, published_at=2019-12-02 14:44:11.154764821 +0000 UTC>
Dec 2 08:44:11 vpc-service-broker-c7855fd67-2jwpr vpc-service-broker DEBUG logging/logging.go:129 Task saved {"logger": "bokchoy", "component": "queue", "queue": {"name": "suspend", "consumers_count": 2}, "duration": "5.132302ms", "task": {"id": "01DV3H37RJMQJHBF4QX1EFD6Y3", "name": "suspend", "status": "waiting", "payload": "{crn:v1:staging:public:is:us-south-1:a/c1cf76af9e6046058d0f1b562eb0ca67::instance:7dbc41ab-0108-4ffb-9b30-79fd6666f74f}", "max_retries": 3, "ttl": "3m0s", "timeout": "3m0s", "published_at": "2019-12-02T14:44:11.154Z", "retry_intervals": "30s, 30s, 30s"}}
Dec 2 08:44:11 vpc-service-broker-c7855fd67-2jwpr vpc-service-broker DEBUG logging/logging.go:129 Task retrieved {"logger": "bokchoy", "component": "queue", "queue": {"name": "suspend", "consumers_count": 2}, "duration": "5.019503ms", "task": {"id": "01DV3H37RJMQJHBF4QX1EFD6Y3", "name": "suspend", "status": "waiting", "payload": "map[crn:crn:v1:staging:public:is:us-south-1:a/c1cf76af9e6046058d0f1b562eb0ca67::instance:7dbc41ab-0108-4ffb-9b30-79fd6666f74f]", "max_retries": 3, "ttl": "3m0s", "timeout": "3m0s", "published_at": "2019-12-02T14:44:11.000Z", "retry_intervals": "30s, 30s, 30s"}}
Dec 2 08:44:11 vpc-service-broker-c7855fd67-2jwpr vpc-service-broker info get suspend <Task name=suspend id=01DV3H37RJMQJHBF4QX1EFD6Y3, status=waiting, published_at=2019-12-02 14:44:11 +0000 UTC>
Dec 2 08:44:11 vpc-service-broker-c7855fd67-2jwpr vpc-service-broker info TOTAL: 0

[pariola]

Hi there, I'm also experiencing this on one particular queue, every other queue writes to the database and is triggered.