rmqtt-plugins 0.1.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" } ]