Queue is a generic interface to abstract the details of implementation of queue systems.
Similar to the package database/sql,
this package implements a common interface to interact with different queue
systems, in a unified way.
Currently, only AMQP queues and an in-memory queue are supported.
The recommended way to install go-queue is:
go get -u gopkg.in/src-d/go-queue.v1/...
This example shows how to publish and consume a Job from the in-memory implementation, very useful for unit tests.
The queue implementations to be supported by the NewBroker should be imported
as shows the example.
import (
...
"gopkg.in/src-d/go-queue.v1"
_ "gopkg.in/src-d/go-queue.v1/memory"
)
...
b, _ := queue.NewBroker("memory://")
q, _ := b.Queue("test-queue")
j, _ := queue.NewJob()
if err := j.Encode("hello world!"); err != nil {
log.Fatal(err)
}
if err := q.Publish(j); err != nil {
log.Fatal(err)
}
iter, err := q.Consume(1)
if err != nil {
log.Fatal(err)
}
consumedJob, _ := iter.Next()
var payload string
_ = consumedJob.Decode(&payload)
fmt.Println(payload)
// Output: hello world!The list of available variables is:
AMQP_BACKOFF_MIN(default: 20ms): Minimum time to wait for retry the connection or queue channel assignment.AMQP_BACKOFF_MAX(default: 30s): Maximum time to wait for retry the connection or queue channel assignment.AMQP_BACKOFF_FACTOR(default: 2): Multiplying factor for each increment step on the retry.AMQP_BURIED_QUEUE_SUFFIX(default:.buriedQueue): Suffix for the buried queue name.AMQP_BURIED_EXCHANGE_SUFFIX(default:.buriedExchange): Suffix for the exchange name.AMQP_BURIED_TIMEOUT(default: 500): Time in milliseconds to wait for new jobs from the buried queue.AMQP_RETRIES_HEADER(default:x-retries): Message header to set the number of retries.AMQP_ERROR_HEADER(default:x-error-type): Message header to set the error type.
Apache License Version 2.0, see LICENSE
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent