[#1385]: release: v2.12.1

.rr.yaml

@@ -1239,7 +1239,7 @@ jobs:
         # If the job has priority set to 0, it will inherit the pipeline's priority. Default: 10.
         priority: 10
 
-        # Number of job to prefetch from the driver.
+        # Number of job to prefetch from the driver until ACK/NACK.
         #
         # Default: 100_000.
         prefetch: 10000
@@ -1303,6 +1303,21 @@ jobs:
         # Default: false
         durable: false
 
+        # Durable exchange (rabbitmq option: https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges)
+        #
+        # Default: true
+        exchange_durable: false
+
+        # Auto-delete (exchange is deleted when last queue is unbound from it): https://www.rabbitmq.com/tutorials/amqp-concepts.html#exchanges
+        #
+        # Default: false
+        exchange_auto_deleted: false
+
+        # Auto-delete (queue that has had at least one consumer is deleted when last consumer unsubscribes) (rabbitmq option: https://www.rabbitmq.com/queues.html#properties)
+        #
+        # Default: false
+        queue_auto_deleted: false
+
         # Delete queue when stopping the pipeline
         #
         # Default: false
@@ -1397,8 +1412,7 @@ jobs:
         # If the job has priority set to 0, it will inherit the pipeline's priority. Default: 10.
         priority: 10
 
-        # Number of jobs to prefetch from the SQS. Amazon SQS never returns more messages than this value
-        # (however, fewer messages might be returned). Valid values: 1 to 10.
+        # Number of jobs to prefetch from the SQS until ACK/NACK.
         #
         # Default: 10
         prefetch: 10

CHANGELOG.md

@@ -1,5 +1,22 @@
 # CHANGELOG
 
+## v2.12.1 (01.12.2022)
+
+###### tags: `roadrunner` `v2.12.1`
+
+## <center> 🚀 v2.12.1 🚀 </center>
+## <center>👀 New: </center>
+
+- ✏ **RR:** Automatically set the `GOMAXPROCS` to match the container CPU quota.
+- ✏ **AMQP plugin:** implement `Status` to check the AMQP connection [PR](https://github.com/roadrunner-server/amqp/pull/33).
+- ✏ **SQS plugin:** `prefetch` option now works as expected. RR will not consume new JOBS when reaches `prefetch` limit, until already accepted messages are not ACK/NACK-ed.
+- ✏ **JOBS(memory) plugin:** `prefetch` option now works as expected (see SQS). You can now emulate FIFO in memory by setting the `prefetch` option to 1.
+
+### <center>🩹 Fixes:</center>
+
+- **gRPC plugin**: server options are applied only when TLS is set. [Discussion](https://github.com/roadrunner-server/roadrunner/discussions/1384).
+- **AMQP plugin**: fix a few typos in the configuration.
+
 ## v2.12.0 (24.11.2022)
 
 # ⚠️ `websocket` and `broadcast` plugins were replaced by the new `centrifuge` plugin.

go.mod

@@ -9,48 +9,48 @@ require (
 	github.com/fatih/color v1.13.0
 	github.com/joho/godotenv v1.4.0
 	github.com/olekukonko/tablewriter v0.0.5
-	github.com/roadrunner-server/amqp/v3 v3.0.2
-	github.com/roadrunner-server/app-logger/v3 v3.0.1
-	github.com/roadrunner-server/beanstalk/v3 v3.0.2
-	github.com/roadrunner-server/boltdb/v3 v3.0.2
-	github.com/roadrunner-server/centrifuge/v3 v3.0.2
-	github.com/roadrunner-server/config/v3 v3.0.2
-	github.com/roadrunner-server/endure v1.4.5
+	github.com/roadrunner-server/amqp/v3 v3.0.4
+	github.com/roadrunner-server/app-logger/v3 v3.0.2
+	github.com/roadrunner-server/beanstalk/v3 v3.0.4
+	github.com/roadrunner-server/boltdb/v3 v3.0.4
+	github.com/roadrunner-server/centrifuge/v3 v3.0.4
+	github.com/roadrunner-server/config/v3 v3.0.4
+	github.com/roadrunner-server/endure v1.4.6
 	github.com/roadrunner-server/errors v1.2.0
-	github.com/roadrunner-server/fileserver/v3 v3.0.2
+	github.com/roadrunner-server/fileserver/v3 v3.0.4
 	github.com/roadrunner-server/goridge/v3 v3.6.2
-	github.com/roadrunner-server/grpc/v3 v3.0.2
-	github.com/roadrunner-server/gzip/v3 v3.0.2
-	github.com/roadrunner-server/headers/v3 v3.0.2
-	github.com/roadrunner-server/http/v3 v3.0.3
-	github.com/roadrunner-server/informer/v3 v3.0.2
-	github.com/roadrunner-server/jobs/v3 v3.0.2
-	github.com/roadrunner-server/kafka/v3 v3.0.2
-	github.com/roadrunner-server/kv/v3 v3.0.2
-	github.com/roadrunner-server/logger/v3 v3.0.1
-	github.com/roadrunner-server/memcached/v3 v3.0.2
-	github.com/roadrunner-server/memory/v3 v3.1.0
-	github.com/roadrunner-server/metrics/v3 v3.1.0
-	github.com/roadrunner-server/nats/v3 v3.0.2
-	github.com/roadrunner-server/otel/v3 v3.0.2
-	github.com/roadrunner-server/prometheus/v3 v3.0.2
-	github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.2
-	github.com/roadrunner-server/redis/v3 v3.0.2
-	github.com/roadrunner-server/reload/v3 v3.0.1
-	github.com/roadrunner-server/resetter/v3 v3.0.1
-	github.com/roadrunner-server/rpc/v3 v3.0.2
-	github.com/roadrunner-server/sdk/v3 v3.0.0
-	github.com/roadrunner-server/send/v3 v3.0.2
-	github.com/roadrunner-server/server/v3 v3.0.2
-	github.com/roadrunner-server/service/v3 v3.0.2
-	github.com/roadrunner-server/sqs/v3 v3.1.0
-	github.com/roadrunner-server/static/v3 v3.0.2
-	github.com/roadrunner-server/status/v3 v3.0.2
-	github.com/roadrunner-server/tcp/v3 v3.0.2
+	github.com/roadrunner-server/grpc/v3 v3.0.5
+	github.com/roadrunner-server/gzip/v3 v3.0.4
+	github.com/roadrunner-server/headers/v3 v3.0.4
+	github.com/roadrunner-server/http/v3 v3.0.5
+	github.com/roadrunner-server/informer/v3 v3.0.4
+	github.com/roadrunner-server/jobs/v3 v3.0.4
+	github.com/roadrunner-server/kafka/v3 v3.0.4
+	github.com/roadrunner-server/kv/v3 v3.0.4
+	github.com/roadrunner-server/logger/v3 v3.0.2
+	github.com/roadrunner-server/memcached/v3 v3.0.4
+	github.com/roadrunner-server/memory/v3 v3.1.3
+	github.com/roadrunner-server/metrics/v3 v3.1.1
+	github.com/roadrunner-server/nats/v3 v3.0.4
+	github.com/roadrunner-server/otel/v3 v3.0.4
+	github.com/roadrunner-server/prometheus/v3 v3.0.4
+	github.com/roadrunner-server/proxy_ip_parser/v3 v3.0.4
+	github.com/roadrunner-server/redis/v3 v3.0.4
+	github.com/roadrunner-server/reload/v3 v3.0.2
+	github.com/roadrunner-server/resetter/v3 v3.0.2
+	github.com/roadrunner-server/rpc/v3 v3.0.4
+	github.com/roadrunner-server/sdk/v3 v3.0.1
+	github.com/roadrunner-server/send/v3 v3.0.4
+	github.com/roadrunner-server/server/v3 v3.0.4
+	github.com/roadrunner-server/service/v3 v3.0.4
+	github.com/roadrunner-server/sqs/v3 v3.1.3
+	github.com/roadrunner-server/static/v3 v3.0.4
+	github.com/roadrunner-server/status/v3 v3.0.4
+	github.com/roadrunner-server/tcp/v3 v3.0.4
 	github.com/spf13/cobra v1.6.1
 	github.com/spf13/viper v1.14.0
 	github.com/stretchr/testify v1.8.1
-	github.com/temporalio/roadrunner-temporal/v2 v2.0.0
+	github.com/temporalio/roadrunner-temporal/v2 v2.0.1
 	go.buf.build/protocolbuffers/go/roadrunner-server/api v1.3.27
 	go.uber.org/automaxprocs v1.5.1
 )
@@ -175,7 +175,7 @@ require (
 	github.com/rabbitmq/amqp091-go v1.5.0 // indirect
 	github.com/rcrowley/go-metrics v0.0.0-20201227073835-cf1acfcdf475 // indirect
 	github.com/rivo/uniseg v0.4.3 // indirect
-	github.com/roadrunner-server/tcplisten v1.2.0 // indirect
+	github.com/roadrunner-server/tcplisten v1.2.1 // indirect
 	github.com/robfig/cron v1.2.0 // indirect
 	github.com/sean-/seed v0.0.0-20170313163322-e2103e2c3529 // indirect
 	github.com/segmentio/asm v1.2.0 // indirect
@@ -227,7 +227,7 @@ require (
 	go.temporal.io/server v1.18.5 // indirect
 	go.uber.org/atomic v1.10.0 // indirect
 	go.uber.org/multierr v1.8.0 // indirect
-	go.uber.org/zap v1.23.0 // indirect
+	go.uber.org/zap v1.24.0 // indirect
 	golang.org/x/crypto v0.3.0 // indirect
 	golang.org/x/mod v0.7.0 // indirect
 	golang.org/x/net v0.2.0 // indirect
@@ -237,7 +237,7 @@ require (
 	golang.org/x/time v0.2.0 // indirect
 	golang.org/x/tools v0.3.0 // indirect
 	google.golang.org/appengine v1.6.7 // indirect
-	google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6 // indirect
+	google.golang.org/genproto v0.0.0-20221130183247-a2ec334bae6f // indirect
 	google.golang.org/grpc v1.51.0 // indirect
 	google.golang.org/protobuf v1.28.1 // indirect
 	gopkg.in/ini.v1 v1.67.0 // indirect