MCPcopy Create free account
hub / github.com/gocelery/gocelery / GetTaskMessage

Method GetTaskMessage

gocelery.go:18–18  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

16type CeleryBroker interface {
17 SendCeleryMessage(*CeleryMessage) error
18 GetTaskMessage() (*TaskMessage, error) // must be non-blocking
19}
20
21// CeleryBackend is interface for celery backend database

Callers 4

TestSendGetFunction · 0.65
GetTaskMessageMethod · 0.65
SendCeleryMessageMethod · 0.65
StartWorkerMethod · 0.65

Implementers 2

RedisCeleryBrokerredis_broker.go
AMQPCeleryBrokeramqp_broker.go

Calls

no outgoing calls

Tested by 1

TestSendGetFunction · 0.52