rmqtt-plugins 0.15.0

Plugin collection for rmqtt, providing authentication, storage, bridges, clustering, and other extensions.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

##--------------------------------------------------------------------
## rmqtt-web-hook
##--------------------------------------------------------------------
## http
#    Method: POST
#    Body: <JSON>
#    Payload: BASE64
## file
#    None
#

# See more keys and their definitions at https://github.com/rmqtt/rmqtt/blob/master/docs/en_US/web-hook.md

##--------------------------------------------------------------------
## Hook General Config
##--------------------------------------------------------------------
# Maximum number of tasks that can be queued before new tasks are rejected.
# Changing this value requires restarting the service to take effect.
queue_capacity = 300_000

# Maximum number of tasks that can be executed concurrently.
# Changing this value requires restarting the service to take effect.
concurrency_limit = 128


## Default urls, supports http and file protocols
#urls = ["file:///var/log/rmqtt/hook.log", "http://127.0.0.1:5656/mqtt/webhook"]
urls = ["file:///var/log/rmqtt/hook.log"]

## Http config
http_timeout = "8s"
#If it fails, try again after approximately 2, 4, 7, 11, 18, or 42 seconds
retry_max_elapsed_time = "60s"
retry_multiplier = 2.5

## Hook rules config
rule.session_created = [{action = "session_created" } ]
rule.session_terminated = [{action = "session_terminated" } ]
rule.session_subscribed = [{action = "session_subscribed"  } ]
rule.session_unsubscribed = [{action = "session_unsubscribed" } ]

rule.client_connect = [{action = "client_connect"}]
rule.client_connack = [{action = "client_connack"} ]
rule.client_connected = [{action = "client_connected" } ]
rule.client_disconnected = [{action = "client_disconnected" } ]
rule.client_subscribe = [{action = "client_subscribe" } ]
rule.client_unsubscribe = [{action = "client_unsubscribe" } ]

rule.message_publish = [{action = "message_publish", topics=["#", "$SYS/#"] }]
rule.message_delivered = [{action = "message_delivered", topics=["#", "$SYS/#"] } ]
rule.message_acked = [{action = "message_acked", topics=["#", "$SYS/#"] } ]
rule.message_dropped = [{action = "message_dropped" } ]