diff options
| -rw-r--r-- | .rr.yaml | 26 | ||||
| -rw-r--r-- | schemas/config/2.0.schema.json | 25 |
2 files changed, 50 insertions, 1 deletions
@@ -1178,6 +1178,11 @@ jobs: # If the job has priority set to 0, it will inherit the pipeline's priority. Default: 10. priority: 1 + # Consume any payload type (not only Jobs structured) + # + # Default: false + consume_all: false + # Durable queue # # Default: false @@ -1246,6 +1251,11 @@ jobs: # Default: 1 tube_priority: 1 + # Consume any payload type (not only Jobs structured) + # + # Default: false + consume_all: false + # Tube name # # Default: default @@ -1278,6 +1288,16 @@ jobs: # Default: 10 prefetch: 10 + # Consume any payload type (not only Jobs structured) + # + # Default: false + consume_all: false + + # Get queue URL only + # + # Default: false + skip_queue_declaration: false + # The duration (in seconds) that the received messages are hidden from subsequent # retrieve requests after being retrieved by a ReceiveMessage request # @@ -1319,7 +1339,6 @@ jobs: # # Should not be empty config: - # Pipeline priority # # If the job has priority set to 0, it will inherit the pipeline's priority. Default: 10. @@ -1330,6 +1349,11 @@ jobs: # Messages to read into the channel prefetch: 100 + # Consume any payload type (not only Jobs structured) + # + # Default: false + consume_all: false + # NATS subject # # Default: default diff --git a/schemas/config/2.0.schema.json b/schemas/config/2.0.schema.json index 63f94ab3..93d6ce8d 100644 --- a/schemas/config/2.0.schema.json +++ b/schemas/config/2.0.schema.json @@ -1175,6 +1175,11 @@ "type": "integer", "default": 100000 }, + "consume_all": { + "description": "Consume all payloads, even not Job structured", + "type": "boolean", + "default": false + }, "queue": { "type": "string", "description": "Queue name", @@ -1238,6 +1243,11 @@ "type": "integer", "default": 100000 }, + "consume_all": { + "description": "Consume all payloads, even not Job structured", + "type": "boolean", + "default": false + }, "tube_priority": { "description": "Beanstalk internal tube priority", "type": "integer", @@ -1267,6 +1277,16 @@ "type": "integer", "default": 100000 }, + "skip_queue_declaration": { + "description": "Get queue URL instead of declaring it", + "type": "boolean", + "default": false + }, + "consume_all": { + "description": "Consume all payloads, even not Job structured", + "type": "boolean", + "default": false + }, "visibility_timeout": { "type": "integer", "description": "The duration (in seconds) for which the call waits for a message to arrive in the queue before returning. If a message is available, the call returns sooner than WaitTimeSeconds. If no messages are available and the wait time expires, the call returns successfully with an empty list of messages.", @@ -1316,6 +1336,11 @@ "type": "integer", "default": 100000 }, + "consume_all": { + "description": "Consume all payloads, even not Job structured", + "type": "boolean", + "default": false + }, "subject": { "description": "NATS subject", "type": "string", |