8c4b087c7c
Git: Ignore testsuite artifacts
2015-10-21 14:29:41 +02:00
a075272f0f
Update rabbitmq-components.mk
2015-10-19 17:35:45 +02:00
300b9acd97
Update erlang.mk
2015-10-19 17:12:42 +02:00
f36a99f998
Update rabbitmq-components.mk
2015-10-19 17:11:41 +02:00
9d5037344d
Initial move to erlang.mk
2015-10-19 12:28:46 +02:00
0e3efda1ab
Merge branch 'stable'
2015-09-30 04:03:26 +08:00
d26b6e1c91
set auto_delete=false for QoS1 subscriptions
2015-09-29 11:23:34 +01:00
1096f3182d
Merge branch 'stable'
2015-09-22 12:38:31 +03:00
87dba24f4b
Rename function
2015-09-22 02:35:19 -07:00
85f9f2df5b
Two more warnings
2015-09-22 02:31:15 -07:00
3981be3e3d
Squash a few warnings in tests
2015-09-22 02:26:22 -07:00
340bb5d70b
refactored tests to use rabbitmq_mqtt:env/1
2015-09-17 23:27:13 +01:00
9039d7398b
added .app file with some configuration used by tests
2015-09-17 23:26:05 +01:00
204b1a59aa
added step to copy .app file from test/src to test/ebin
2015-09-17 23:24:42 +01:00
1544360485
removed unused test
2015-09-17 23:23:49 +01:00
0213ec24e9
use assertEqual instead of pattern matching
2015-09-17 15:40:10 +01:00
f6d7f16941
refactored coerce to use to_binary identity function
2015-09-17 15:00:33 +01:00
578ac7169b
coerce default_user & default_pass
2015-09-17 14:50:17 +01:00
2b58ca1247
added unit tests
2015-09-17 14:26:22 +01:00
f196f05373
coerce exchange and vhost to binary
2015-09-17 13:03:53 +01:00
b633549801
revert warning fix
2015-07-14 11:03:31 +01:00
8fb4904fdc
whitespace changes
2015-07-14 10:56:02 +01:00
bafb39f5f0
don't use `apply/2`
2015-07-14 10:47:39 +01:00
6bc3579023
fix compile warnings
2015-07-14 10:47:01 +01:00
fabf2614ab
rename `K` to `Fn`
2015-07-14 10:34:25 +01:00
868b845101
change resource kind to `topic`
2015-07-14 10:31:42 +01:00
f293972f3c
check authorization at mqtt topic level
2015-06-30 09:08:26 +01:00
8712428268
Merge branch 'stable'
2015-05-24 04:55:07 +03:00
692c6a7060
(c) year
2015-05-24 04:54:58 +03:00
b52aed4a69
Merge branch 'stable'
2015-05-14 17:19:24 +03:00
d89eed50e9
Adapt to Java client API change in stable
2015-05-14 14:59:50 +03:00
dad4ea314a
Merge branch 'stable'
2015-05-07 13:02:46 +02:00
aa6872bb5c
test/Makefile: Use $MAKE instead of hard-coding "make"
...
This one was harmless but let's do this for consistency's sake.
References #23 .
2015-05-07 13:01:13 +02:00
9e9c2dec8c
Merge branch 'stable'
2015-05-06 19:13:42 +02:00
386bba589e
Use $MAKE instead of hard-coding "make"
...
$MAKE is passed down by Umbrella's do-package.mk. This fixes the
testsuite on systems where "make" is not GNU make.
Fixes #23 .
2015-05-06 19:09:27 +02:00
f2dc1d75cb
Merge branch 'stable'
2015-05-01 00:49:48 +03:00
5a87bddf0d
Ignore test/.idea
2015-05-01 00:49:21 +03:00
fc3123c7a6
Update README.md
2015-04-28 23:49:46 +03:00
8d359a8ea4
Update README.md
2015-04-28 23:47:08 +03:00
0f4db19311
Use a higher call timeout here
2015-04-26 19:36:15 +03:00
0075bea594
Merge branch 'master' into rabbitmq-mqtt-16
2015-04-26 18:36:13 +03:00
e099bf21c0
Tests for retained messages
2015-04-26 04:51:30 +03:00
e8ae92a910
Don't crash if we get a PUBACK for unknown message
...
E.g. due to bogus clients that interpret QoS downgrade
in curious ways.
2015-04-26 04:51:04 +03:00
3c30c87767
Change how retained message delivery QoS is calculated
...
We now take the lower value of message QoS and
SUBSCRIBE QoS, per community feedback.
2015-04-25 19:35:47 +03:00
36374ca849
Fix a badmatch
2015-04-25 19:34:59 +03:00
6ac8d4def5
Implement a DETS-based message store, refactor
2015-04-23 02:48:06 +03:00
c6979e0435
Handle vhost creation and deletion events
2015-04-22 01:14:15 +03:00
df47dbd77a
Refactor
2015-04-22 00:31:23 +03:00
b79bd7efb4
Trap exits so that terminate/2 is invoked
2015-04-21 19:07:09 +03:00
2c6c21a4ef
Undo this accidental change
2015-04-21 17:39:20 +03:00
a4f4d92fd7
Switch to permanent type
2015-04-21 15:18:48 +03:00
0b6e7d5714
put/get/delete operations for retained message store
...
Yet to be done: dump and restore to disk on shutdown
and boot.
2015-04-21 14:26:46 +03:00
1c935cfb21
Process bits for retained message stores
2015-04-18 03:55:34 +03:00
204dfecea0
Correct a typo
2015-04-16 23:37:23 +03:00
8910ce56c6
Correct a typo
2015-04-16 23:36:57 +03:00
7b5452415f
Ignore test/.idea
2015-04-15 05:53:32 +03:00
bd6a283e79
Ignore test/.idea/*
2015-03-26 16:59:28 +03:00
f240c3ded1
Sync CONTRIBUTING.md with the template one
2015-02-20 17:09:21 +03:00
92bc2c21d0
Merge branch 'stable'
2015-02-19 18:19:42 +01:00
825bf9e580
Convert .hgignore to .gitignore
2015-02-19 17:26:01 +01:00
df0bff310a
Sync CONTRIBUTING.md with the template one
2015-02-18 00:20:51 +03:00
6805dfeffa
Sync CONTRIBUTING.md with the template one
2015-02-18 00:09:54 +03:00
8b3687d042
Merge branch 'stable'
2015-02-17 21:17:55 +01:00
c7546ef628
Remove the "moved to GitHub" warning.
2015-02-17 21:17:45 +01:00
8ec8c2ee97
README.md: Warn about the move to GitHub
2015-02-17 18:12:53 +01:00
1fb4e838f2
README.md: Warn about the move to GitHub
2015-02-17 18:12:39 +01:00
b853a637b3
merge stable into default
2015-02-10 15:54:30 +03:00
63ff3a105a
MQTT processor should link its channel
2015-02-10 15:52:02 +03:00
dd67f9d51c
merge stable into default
2015-01-31 12:02:19 +03:00
9546c4dcc5
Make sure to send LW&T when connection is closed due to a keep-alive timeout
2015-01-31 11:26:49 +03:00
92cd34594d
stable to default
2014-12-02 12:40:59 +00:00
a725ddbcf8
Merge bug26480 (again)
2014-11-28 15:15:08 +00:00
7b06606359
Oops, that might not exist
2014-11-28 15:14:11 +00:00
75fccac9b9
merge heads of default
2014-11-28 18:11:41 +03:00
117d556ea2
ssl_cert_login and allow_anonymous probably won't be explicitly set to undefined
2014-11-28 18:08:42 +03:00
f8890a5c25
Drive by change: correct error message arguments here
2014-11-28 17:40:38 +03:00
ad3af36155
Don't swallow exceptions in mqtt_processor:process_frame/1
2014-11-28 17:40:16 +03:00
379ecfd911
Simplify. Enforce always running SSL tests. Don't create global variables in the Makefile namespace.
2014-11-28 14:39:39 +00:00
fe541380b5
Make sure ssl_cert_login has a default value
2014-11-28 16:57:27 +03:00
45826041aa
Oops
2014-11-28 11:30:14 +00:00
746495fc43
Rename this to avoid conflict with STOMP. Something of a hack, but it seems to work.
2014-11-28 09:46:53 +00:00
f50bfda0b1
Backout more package.mk changes
2014-11-27 23:42:04 +03:00
5652860bc4
Backout more package.mk changes
2014-11-27 23:41:49 +03:00
f282d32b1b
Backed out changeset aed1b2464613
2014-11-27 23:41:15 +03:00
8c94676c73
Add a rule for TEST_EBIN_DIR
2014-11-27 16:14:15 +03:00
53ad3c7950
Attempt to fix CI
2014-11-27 15:48:02 +03:00
7276dab237
Attempt to fix CI creating test/ebin in one more place
2014-11-27 14:49:51 +03:00
779a526837
Use absolute paths here
2014-11-26 01:04:15 +03:00
073cc57dcb
Don't require peer cert
2014-11-25 23:51:30 +03:00
0dc8b8e22d
Require TLS certificate in TLS authentication tests
...
Otherwise we get platform-specific failures and even generic client exceptions.
This case is potentially valid but is likely to be really rare (if you use TLS,
you probably also authenticate, using credentials or the certificate).
In the original patch this scenario was expected to fail. We now go back
to square 1.
2014-11-25 23:44:42 +03:00
b1147f355c
Pick most recent TLS version available
2014-11-25 23:20:38 +03:00
d68f2b063e
Use TLS v1.1 because v1.2 is not available on CI machines
2014-11-25 21:46:23 +03:00
df5eb6aa57
Certificate authencation needs to be enabled explicitly, as with STOMP
...
Using the same ssl_cert_login app key.
2014-11-24 21:22:09 +03:00
0e298907aa
Make it clear that this test does not expect an authentication failure
2014-11-24 21:21:20 +03:00
089ef7e86f
Rename TLS test package
2014-11-24 17:01:10 +03:00
a0def030d2
Ditto
2014-11-24 16:59:19 +03:00
06f8a2db70
Cosmetics
2014-11-24 16:58:48 +03:00
6eca0b71f8
Only ignore test/build/ but not test/build.xml and test/build.properties
2014-11-24 13:13:27 +03:00
cee8eb2fd8
Client MQTT authentication using x509 certificates
...
Original patch by Eric Rauer.
2014-11-21 14:54:33 +00:00
147c0c3a3c
poodle_check/1 has to come after ensure_ssl/0.
2014-10-20 15:54:48 +01:00
73f3fc4d40
Oops
2014-10-20 14:06:22 +01:00
7305f70289
Test for old Erlang, and shout if we are vulnerable.
2014-10-20 14:05:30 +01:00
58a8c6a0f0
Use human-readable MQTT versions in connection adapter info
2014-08-25 13:43:11 +04:00
f05ca5e4c2
Use manual delivery flow control
2014-08-11 14:26:27 +04:00
de51bab488
Eliminate a few compiler warnings
2014-07-04 12:10:00 +04:00
9f8a6a3f18
merge stable into default
2014-07-04 12:01:56 +04:00
fe37e1a629
Log correctly closed MQTT connections
...
Just like we do for AMQP.
2014-07-04 11:38:50 +04:00
96cf2cd364
Include MQTT connection (reader) pid in the log message
...
Just like we do for AMQP connections.
2014-07-04 11:38:27 +04:00
cf7b440aa4
merge stable into default
2014-07-03 21:41:36 +04:00
28fab87eac
Avoid ugly error messages when the collector terminates on abrupt reader/processor termination
...
They are harmless but can really confuse the user.
2014-07-03 21:37:25 +04:00
40c6380095
Handle MQTT processor errors more gracefully
2014-07-03 21:36:17 +04:00
881251d5f3
Special case TLS alert "unknown CA", which is very common
...
Indicates a generic certificate verification problem, which we mention.
2014-07-03 16:13:27 +04:00
a84a8a13a0
Further TLS upgrade error message improvements
...
* Include connection string
* Slightly more specific messages for handshake failure and other TLS alerts
2014-07-03 16:03:51 +04:00
ca67de6b7b
Improve error messages for failing connections and TLS upgrades
2014-07-03 15:46:59 +04:00
8a2525ec28
Ignore debug/*
2014-06-24 05:01:51 +04:00
2aa625b114
err => error
2014-05-25 10:19:01 +04:00
5d895a904d
merge bug26189 into stable (again)
2014-05-21 11:22:13 +04:00
750eeb593d
Inline stop and close_connection
2014-05-21 11:13:12 +04:00
7ad72a96cf
Let terminate/2 close direct client connection
2014-05-21 11:02:35 +04:00
fb62c75946
Use existing function to close connection
2014-05-21 10:47:54 +04:00
dfabf68e2e
Explain
2014-05-21 10:40:12 +04:00
1d4e2a00c5
Close direct connection cleanly when mqtt_reader terminates
...
Otherwise the connection will receive {'EXIT', Pid, shutdown} which it does
not expect and log a nasty crash report.
2014-05-21 10:36:30 +04:00
4232991625
Start collector before client_sup so that it's stopped later than the other
2014-05-21 09:22:38 +04:00
98b7de9dc6
List rabbit_mqtt_collector in rabbit_mqtt_sup child spec
...
To make sure the collector is shut down as expected.
2014-05-21 08:35:52 +04:00
c9c5899a1f
Make sure rabbit_client_sup will terminate rabbit_mqtt_client_sup and not keepalive_sup
2014-05-21 08:15:24 +04:00
94820cefaa
Make rabbit_mqtt_sup a supervisor2
2014-05-21 07:41:52 +04:00
31dcbfb85d
Cosmetic (and test bz notification)
2014-04-15 14:18:37 +01:00
9cab3b8af4
Eliminate a warning
2014-04-15 15:21:20 +04:00
1c63bf716a
Initialise MQTT reader asynchronously, narrow the gap with rabbit_reader
2014-04-15 15:20:49 +04:00
bc1cdd77d5
merge stable into default
2014-03-31 13:29:39 +01:00
299bcc1d5b
eliminate race in testConnectFirst test
...
the test was highly timing sensitive; it published 1000 messages and
expected one of those publishes to fail due to the socket getting
closed by the server when encountering the first publish. So if the
client was quick enough / the server slow enough, all the publishes
would go through before the server processed the first one and closed
the socket. Cue test failure.
The new test sends an mqtt 'ping' and waits for a response. Not only
is this non-racy and doesn't require any magic timouts, it also is a
better exercise of the server logic: A 'publish' on a connection which
hasn't seen a 'connect' will fail anyway, even w/o the server code in
place that detects the missing 'connect', since processing a 'publish'
requires an amqp client connection, which in turn is only established
on 'connect'. By contrast, a 'ping' does not require an amqp client
connection. Hence removing the "make sure we have seen a 'connect'"
logic now results in a 'ping' response being sent, which makes the
test fail, as expected.
2014-03-31 13:26:58 +01:00
56860f2009
cosmetic
2014-03-31 13:17:29 +01:00
35dc34bfff
Better 3.1.1 compatibility
2014-03-19 12:05:42 +00:00
4e07b1d640
Update copyright for 2014
2014-03-17 17:25:23 +00:00
04577ad084
Check source of user is acceptable.
2014-02-18 17:33:33 +00:00
23019b084f
Cosmetic: fix indentation.
2014-02-18 17:33:00 +00:00
2206e2ae64
Allow running tests on a Mac
2014-02-03 17:51:02 +00:00
24644c8b25
stable to default
2014-01-30 15:34:48 +00:00
f06453a0b9
Publish persistent messages for QoS 1.
2014-01-30 15:33:59 +00:00
c2da97cf65
Renames and codedocs
2014-01-20 10:33:27 +00:00
62c0d40f06
Prevent child calling its supervisor
2014-01-07 10:37:51 +00:00
8d950b1f26
Detection of absent keepalives
2014-01-06 17:50:02 +00:00
f98298a818
Merged stable into default
2013-12-04 15:13:57 +00:00
d65d20b8b9
Termination conditions when receiving multiple acks
2013-12-04 14:59:22 +00:00
b6c09249e6
stable to default
2013-11-19 16:32:46 +00:00
4568741872
Support vhosts as part of username
2013-11-18 12:00:47 +00:00
f87e71af92
Unregister client IDs correctly
2013-11-14 13:48:14 +00:00
d0f045bf1f
Eliminate use of gen_server:call/2.
2013-10-24 12:22:34 +01:00
9bde9ce822
Revert part of f438760bff27 since the exception is now an IOException.
2013-10-03 11:34:09 +01:00
69b255af77
Propagate Erlang client API change
2013-09-24 11:24:21 +01:00
0369111d32
stable to default
2013-09-16 14:45:09 +01:00
eb080c2704
Only unregister client id when necessary
2013-09-16 11:36:52 +01:00
e2c9f63d0c
updated README to point to /mqtt.html
2013-08-19 09:14:52 -06:00
50f162ea0d
Swap connect and setting callback
2013-07-31 15:28:22 +01:00
23a100db9a
Merged stable into default
2013-07-31 13:57:31 +01:00
48fbca2834
Automatically subscribe when connecting
2013-07-26 17:43:25 +01:00
bb95f34e47
s/VMware/GoPivotal/g
2013-07-01 10:49:14 +01:00
73d32f6c6b
Specify the version of the paho MQTT client to use, and some API tweaks to use the latest version. Why not just use the version that used to work? Well, it required some non-standard ant stuff to build.
2013-04-15 16:38:10 +01:00
c95996d80a
merge bug25487 into default
2013-04-05 13:32:59 +01:00
ed3ee2a2ff
client_sup API change
2013-04-05 12:42:32 +01:00
f225804df5
Transplant reverse of 8c13f168cf00
2013-04-04 17:08:30 +01:00
809fa199ca
Unfix bug
2013-04-04 16:41:57 +01:00
2e74c028c0
client_sup API change
2013-04-04 16:41:20 +01:00
1617d8c66d
Propagate API change of rabbit_client_sup
2013-03-14 16:13:03 +00:00
93dbe20ede
Correct use of client_id and worker
2013-03-13 16:11:08 +00:00
bd0f6f11ff
Handle connection abort while opening more gracefully
2013-03-01 10:49:23 +00:00
5eb96838ab
merge stable into default
2013-02-28 13:08:55 +00:00
ffbe2c6560
Hibernate after opening connection and when waiting for data
2013-02-28 13:04:59 +00:00
3458e1ab3e
cosmetic
2013-02-28 12:27:23 +00:00
cc5259ea9c
Silence warnings
2013-02-27 11:01:09 +00:00
e97b07fa0f
socket buffer size tuning has moved into the tcp_acceptor
2013-02-26 15:33:13 +00:00
82f8a8af9b
stable to default
2013-01-24 13:15:54 +00:00
f973d137c3
Update copyright 2013
2013-01-23 13:06:40 +00:00
441a099dd0
API change
2013-01-09 12:06:09 +00:00
cb693d294a
API change
2013-01-09 11:18:44 +00:00
fa2818637e
Cosmetic
2013-01-08 16:29:04 +00:00
62f7da67ac
Use amqp_direct_connection:socket_adapter_info/1.
2013-01-08 16:25:30 +00:00
cc685ac724
address -> host.
2012-11-19 16:39:36 +00:00
0be8fc79af
Establish stable branch
2012-11-19 16:37:20 +00:00
ad7d5bdbf0
Turn off file-based client persistence in tests
2012-11-13 11:30:17 +00:00
44d9fa8b17
Tests require Java AMQP
2012-11-12 13:35:35 +00:00
0f30448a51
Use binaries in headers
2012-11-06 10:32:38 +00:00
7a10b4a7ec
Interoperability fixes
2012-11-05 20:30:45 +00:00
b88a0e3373
Increase test delay
2012-09-25 09:52:41 +01:00
43bd7f0188
Merge bug25089
2012-09-21 15:07:35 +01:00
57cd05f0ed
Every other plugin uses :=, and this is preventing the CI misc plugins thing from removing this.
2012-09-19 17:09:13 +01:00
f574b2dcb6
Authenticate via direct client
2012-09-19 15:34:42 +01:00
11c2e485ec
Prefer https to git protocol for firewall reasons
2012-09-17 15:37:02 +01:00
03dc8b5849
Make tests run from umbrella and pass more reliably
2012-09-17 14:57:31 +01:00
2812742f8e
Correct log method
2012-09-12 16:28:24 +01:00
0a53188d37
Typo
2012-09-12 14:37:45 +01:00
59e92bc6d8
Preview release build changes
2012-09-12 14:34:41 +01:00
a19130be7f
Document configuration
2012-09-12 12:18:39 +01:00
cfcdf7a59b
More consistent naming of credit flow state
2012-08-21 16:45:14 +01:00
c3801689b2
Backout changeset 641cfc6d09b7
2012-08-21 16:38:14 +01:00
13a61caab4
Remove unnecessary configuration
2012-08-21 16:22:31 +01:00
2a716fac2b
Clearer separation between reader and processor
2012-08-20 17:30:13 +01:00
d24a5d7f2a
Register collector name differently
2012-08-17 15:14:40 +01:00
a7a58ad66a
Updated adapter into record name, safer logging, macro corrections
2012-08-17 15:05:14 +01:00
a6856a4a04
Improvements around delivery handling
2012-08-16 18:09:21 +01:00
37761141cb
Name topic translation methods more sensibly
2012-08-16 18:01:45 +01:00
8d52799853
Removed adapter info from state
2012-08-16 17:56:50 +01:00
a53c389211
Remove implicit rules for compiling java
2012-08-10 10:16:15 +01:00
c904f78b2e
Run tests from Makefile
2012-08-09 18:55:45 +01:00
c55ca8584e
Add conservative prefetch limit
2012-08-09 13:52:19 +01:00
a225aa3705
Make register not require unregister first. Duplicate detection is now done in the register call.
2012-08-08 13:37:59 +01:00
8a53099fa8
Revert c493777cbfc5, I was being dumb, it won't match due to being in a closure.
2012-08-08 13:30:18 +01:00
85727eafc7
Seems a bit cleaner to ignore undefined here.
2012-08-08 13:09:50 +01:00
75620477ab
Simplify
2012-08-08 12:49:53 +01:00
1eef766311
Remove that {go, ...} gs call.
2012-08-08 12:47:24 +01:00
02f375a3c0
Add client id collector
2012-08-06 17:58:15 +01:00
d3f4a2dc24
Updates
2012-08-05 23:52:54 +01:00
1b9350fe03
Handle QoS1 duplicate publishes
2012-07-16 22:52:53 +01:00
ec215b34bd
Clean sessions, and anonymous connections
2012-07-16 14:57:31 +01:00
c553880ac7
Avoid a separate erlang process for processor
2012-07-13 16:32:13 +01:00
f79bf51275
Tests
2012-07-05 18:08:23 +01:00
9783db3f5d
Rudimentary unsubscribe support
2012-07-04 17:47:07 +01:00
78b41c8fc0
Basic subscription and heartbeat response
2012-07-04 16:31:30 +01:00
1603079761
Basic authentication and publishing
2012-07-03 17:35:18 +01:00
f195facf1c
Sufficient parsing to accept connection
2012-07-03 09:55:31 +01:00
e973267fcf
Protocol adapter skeleton
2012-06-26 17:57:24 +01:00
Jean-Sébastien Pédron
Jean-Sébastien Pédron
Michael Klishin
Giuseppe Privitera
Michael Klishin
ash-lshift
Michael Klishin
Michael Klishin
Simon MacMullen
Matthias Radestock
Emile Joubert
Alvaro Videla
Tim Watson