x/beanstalkdTube component: v0.29.0+ Beanstalkd producer, supporting operations such as Put, PeekReady, PeekDelayed, PeekBuried, Kick, Stat, and Pause.

Requires the additional extension library: rulego-components (opens new window) Requires configuration of component connection reuse (opens new window). Different nodes reuse the connection through component connection reuse to maintain a consistent client instance (after a Beanstalkd client subscribes to a message, it locks the current client, preventing other clients from operating on the message).

Configuration

Field	Type	Description	Default Value
server	string	Beanstalkd server address	127.0.0.1:11300
tube	string	Required, Tube name, allows the use of ${} placeholder variables	default
cmd	string	Required, command name, supports Put, PeekReady, PeekDelayed, PeekBuried, Kick, Stat, Pause	Stat
body	string	Message body content, allows the use of ${} placeholder variables, parameter for Put command
pri	string	Priority, allows the use of ${} placeholder variables, parameter for Put command
delay	string	Delay time, allows the use of ${} placeholder variables, parameter for Put command
ttr	string	Maximum execution time in seconds for a Job, allows the use of ${} placeholder variables, parameter for Put command
kickBound	string	Bound parameter for Kick command, allows the use of ${} placeholder variables
pauseTime	string	Time parameter for Pause command, allows the use of ${} placeholder variables

Configuration Example

{
"ruleChain": {
"id": "f5G9y8GzpgDY",
"name": "Beanstalkd Node Test",
"debugMode": false,
"root": true,
"disabled": false,
"additionalInfo": {
"createTime": "2025/01/15 21:50:47",
"description": "",
"layoutX": "700",
"layoutY": "100",
"message": "the rule chain has been disabled",
"updateTime": "2025/01/17 14:31:16",
"username": "admin"
}
},
"metadata": {
"endpoints": [
{
"id": "node_2",
"additionalInfo": {
"layoutX": 450,
"layoutY": 160
},
"type": "endpoint/http",
"name": "API",
"debugMode": false,
"configuration": {
"allowCors": true,
"server": ":6333"
},
"processors": null,
"routers": [
{
"id": "KOUXvKLg1Ml2",
"params": [
"POST"
],
"from": {
"path": "/msg/add",
"configuration": null,
"processors": [
"setJsonDataType"
]
},
"to": {
"path": "f5G9y8GzpgDY:node_4",
"configuration": null,
"wait": true,
"processors": [
"responseToBody",
"metadataToHeaders"
]
}
},
{
"id": "Ud6fjHltHyKg",
"params": [
"POST"
],
"from": {
"path": "/msg/del",
"configuration": null,
"processors": [
"setJsonDataType"
]
},
"to": {
"path": "f5G9y8GzpgDY:node_8",
"configuration": null,
"wait": true,
"processors": [
"responseToBody",
"metadataToHeaders"
]
}
},
{
"id": "HlgiXu67EWBX",
"params": [
"POST"
],
"from": {
"path": "/msg/release",
"configuration": null,
"processors": [
"setJsonDataType"
]
},
"to": {
"path": "f5G9y8GzpgDY:node_15",
"configuration": null,
"wait": true,
"processors": [
"responseToBody"
]
}
}
]
}
],
"nodes": [
{
"id": "node_4",
"additionalInfo": {
"layoutX": 950,
"layoutY": 160
},
"type": "x/beanstalkdTube",
"name": "Put",
"debugMode": true,
"configuration": {
"body": "${msg.body}",
"cmd": "Put",
"putBody": "${msg.body}",
"server": "ref://local_beanstalkdTube",
"tube": "${msg.tube}"
}
},
{
"id": "node_8",
"additionalInfo": {
"layoutX": 900,
"layoutY": 400
},
"type": "x/beanstalkdWorker",
"name": "Del",
"debugMode": true,
"configuration": {
"cmd": "Delete",
"jobId": "${msg.id}",
"server": "ref://local_beanstalkdWorker",
"tube": "${msg.tube}"
}
},
{
"id": "node_13",
"additionalInfo": {
"layoutX": 850,
"layoutY": 550
},
"type": "x/beanstalkdWorker",
"name": "Release",
"debugMode": true,
"configuration": {
"cmd": "Release",
"jobId": "${id}",
"server": "ref://local_beanstalkdWorker",
"tube": "${tube}"
}
},
{
"id": "node_15",
"additionalInfo": {
"layoutX": 500,
"layoutY": 530
},
"type": "x/beanstalkdWorker",
"name": "ReserveJob",
"debugMode": true,
"configuration": {
"cmd": "ReserveJob",
"jobId": "${msg.id}",
"server": "ref://local_beanstalkdWorker",
"tube": "${msg.tube}"
}
}
],
"connections": [
{
"fromId": "node_15",
"toId": "node_13",
"type": "Success"
}
]
}
}

Relation Type

Success: Execution successful, the message is sent to the Success chain. Failure: Execution failed, the message is sent to the Failure chain.

Execution Result

Referencing the return value of the Beanstalkd command execution, it is converted to the RuleMsg format and sent to the rule chain: data: Message content dataType: JSON type: Default is empty metadata: Message metadata, including information such as id, tube, etc.