ab46563c45
Merge branch 'stable'
2017-07-31 10:17:08 +02:00
8a9190a43f
Log MQTT processor log messages with connection sink.
...
Fixes #142
2017-07-27 14:01:17 +01:00
bcbae3757c
Whitespace
2017-06-15 10:56:00 -07:00
81ab03c133
Add client_id as an topic authz expandable variable
...
References rabbitmq/rabbitmq-server#1229
2017-06-07 14:41:59 +02:00
28b3c4d46f
Replace dicts with maps for mqtt.
2017-04-24 13:45:37 +01:00
a1b46471fd
Merge branch 'stable'
2017-04-02 22:02:20 +03:00
fff8f52901
(c) year
2017-04-02 21:48:53 +03:00
fba3782869
Check topic access when sending last will
...
The check is actually already done at the AMQP level, but this commit
adds an "upstream" check, a more specific warning message, and a test.
Fixes #114
2017-02-21 16:13:07 +01:00
1bc5c7afd2
Add support for proxy protocol
...
References rabbitmq/rabbitmq-server#589
2017-02-07 17:22:14 +01:00
96aaf35900
Add topic authorisation for consumption
...
Part of rabbitmq/rabbitmq-server#1085
2017-01-23 12:10:23 +01:00
8eb40110d3
Wording
2017-01-16 16:16:54 +03:00
8e505e9af0
Let only message in topic permission violation log
...
Not tuple.
References rabbitmq/rabbitmq-server#505
2017-01-16 10:54:35 +01:00
3695c5826e
Handle topic authorisation failure properly
...
Plugin handles exit signal coming from the AMPQ core,
logs, and closes the client connnection (instead of letting
the whole process tree crash with scary log messages).
References rabbitmq/rabbitmq-server#505
2017-01-16 09:54:16 +01:00
85636953a4
Use check_topic_access on publishing
...
check_resource_access used to be called with
the MQTT topic as resource name and kind = topic.
It makes more sense now to call check_topic_access
with the exchange as resource name, kind = topic,
and routing key in the context.
References rabbitmq/rabbitmq-server#505
2016-12-29 16:34:19 +01:00
cfcde1d143
Merge branch 'stable'
2016-12-20 00:50:04 +03:00
b6c6dc7769
Log in a more human readable format
2016-12-20 00:42:06 +03:00
1ab92e897c
Wording
2016-12-19 22:51:05 +03:00
e250fa048f
Use coercion module for integer-to-binary coercion
...
Fixes #111
2016-12-19 17:53:20 +01:00
87628f9f51
Use binary for port-to-vhost mapping key
...
Behaves better as a JSON document key than an integer.
Fixes #111
2016-12-19 17:36:18 +01:00
b8344cdc27
Map client connection vhost to a port
...
Fixes #111
2016-12-19 15:00:43 +01:00
d1c2474a89
Merge branch 'stable'
2016-12-16 10:59:10 +01:00
7e03af30fd
Introduce mqtt_default_vhosts global parameter
...
Fixes #73
2016-12-13 14:46:15 +01:00
8f9e8489c2
Optionally map user certificate to virtual host
...
Use a global runtime parameter to map the DN of the certificate
to a virtual host.
Fixes #73
2016-12-09 16:48:47 +01:00
8216cb12f1
Merge branch 'stable'
2016-12-07 15:48:04 +01:00
88820d02d9
Don't crash for clients without a last will
...
References #74
2016-12-07 11:21:47 +01:00
b1627afe81
Gracefully close connections to non-existent virtual hosts
...
Return CONNACK 4 code when the virtual host doesn't exist.
The MQTT description for this return code states "The data in
the user name or password is malformed", which not exactly
accurate but better than a pending or abruptly closed connection.
The server logs also a more meaningful message.
Fixes #100
2016-12-06 16:09:50 +01:00
f411a74e10
Test list_mqtt_connections command
2016-12-06 14:24:45 +00:00
76c0a415e5
Merge branch 'master' into rabbitmq-cli-121
2016-12-05 19:56:24 +03:00
a025592ae9
A CLI command to list mqtt connections
2016-12-05 14:58:19 +00:00
bc8e2541bd
Merge branch 'stable'
2016-12-05 14:27:40 +03:00
97aa1ef4ae
Destructure this right in function head
2016-12-05 14:25:15 +03:00
a7a0174a41
Retain last will message
...
Fixes #74
2016-12-05 11:05:30 +01:00
c510fef54a
Merge branch 'stable'
2016-09-02 02:07:46 +03:00
ee213084f8
Wording, naming
2016-09-02 01:33:34 +03:00
4b688b9e63
Make MQTT authentication correspond with docs. Added tests
2016-09-01 16:54:51 +01:00
2626696498
Formatting
2016-05-20 14:07:04 +01:00
fcdff84cca
Merge pull request #80 from tiagodeoliveira/unnecessary_user_login_check
...
Removing unnecessary check_user_login on process_login
2016-05-20 14:06:56 +01:00
f2b4d32693
Formatting
2016-05-20 14:04:10 +01:00
4e7d7abc17
Using internal user from amqp client
2016-05-18 10:11:50 -03:00
61c3f61b64
Removing unnecessary check_user_login that executes authentication method twice.
...
During the amqp_connection:start the check_user_login method is already executed, when it is called again it will call the user_login_authentication again, it makes the authentication to be executed twice in a role, and it raises a problem when using salted passwords.
2016-05-11 14:35:28 -03:00
84871d5e7f
Merge branch 'stable'
2016-04-22 22:36:02 +01:00
e72eb1acbf
Revert redundant nack
2016-04-22 12:32:01 +01:00
0cae4fc7fe
Set session_present flag
2016-04-22 12:28:08 +01:00
25538025df
Merge branch 'stable'
2016-03-04 14:45:33 +03:00
b12d16ef71
Use 0 for frame_max
...
Atoms break HTTP API clients in statically typed languages, e.g. Go
and Java
2016-03-04 13:58:59 +03:00
30ca7ce8c1
Set product to "MQTT client"
...
Not much more specific but a bit more suitable.
2016-03-04 13:35:53 +03:00
15d23e4474
Cosmetics
2016-03-04 13:34:53 +03:00
439d8521aa
Emit stats for management UI
2016-03-03 14:59:53 +01:00
738f263798
MQTT connections use exactly one channel
2016-03-03 14:59:53 +01:00
7b42c20b7e
Allow passing the adapter info on processor init
2016-03-03 14:59:53 +01:00
Jean-Sébastien Pédron
Daniil Fedotov
Luke Bakken
Arnaud Cogoluègnes
Michael Klishin
Michael Klishin
Daniil Fedotov
Tiago Oliveira
Loïc Hoguin