Commit Graph

51 Commits

Author SHA1 Message Date
Michael Klishin 58a8c6a0f0 Use human-readable MQTT versions in connection adapter info 2014-08-25 13:43:11 +04:00
Michael Klishin f05ca5e4c2 Use manual delivery flow control 2014-08-11 14:26:27 +04:00
Michael Klishin 40c6380095 Handle MQTT processor errors more gracefully 2014-07-03 21:36:17 +04:00
Matthias Radestock bc1cdd77d5 merge stable into default 2014-03-31 13:29:39 +01:00
Matthias Radestock 56860f2009 cosmetic 2014-03-31 13:17:29 +01:00
Emile Joubert 35dc34bfff Better 3.1.1 compatibility 2014-03-19 12:05:42 +00:00
Simon MacMullen 4e07b1d640 Update copyright for 2014 2014-03-17 17:25:23 +00:00
Simon MacMullen 04577ad084 Check source of user is acceptable. 2014-02-18 17:33:33 +00:00
Simon MacMullen 23019b084f Cosmetic: fix indentation. 2014-02-18 17:33:00 +00:00
Simon MacMullen 24644c8b25 stable to default 2014-01-30 15:34:48 +00:00
Simon MacMullen f06453a0b9 Publish persistent messages for QoS 1. 2014-01-30 15:33:59 +00:00
Emile Joubert 8d950b1f26 Detection of absent keepalives 2014-01-06 17:50:02 +00:00
Emile Joubert f98298a818 Merged stable into default 2013-12-04 15:13:57 +00:00
Emile Joubert d65d20b8b9 Termination conditions when receiving multiple acks 2013-12-04 14:59:22 +00:00
Simon MacMullen b6c09249e6 stable to default 2013-11-19 16:32:46 +00:00
Emile Joubert 4568741872 Support vhosts as part of username 2013-11-18 12:00:47 +00:00
Emile Joubert f87e71af92 Unregister client IDs correctly 2013-11-14 13:48:14 +00:00
Emile Joubert 69b255af77 Propagate Erlang client API change 2013-09-24 11:24:21 +01:00
Simon MacMullen 0369111d32 stable to default 2013-09-16 14:45:09 +01:00
Emile Joubert eb080c2704 Only unregister client id when necessary 2013-09-16 11:36:52 +01:00
Emile Joubert 23a100db9a Merged stable into default 2013-07-31 13:57:31 +01:00
Emile Joubert 48fbca2834 Automatically subscribe when connecting 2013-07-26 17:43:25 +01:00
Simon MacMullen bb95f34e47 s/VMware/GoPivotal/g 2013-07-01 10:49:14 +01:00
Simon MacMullen 82f8a8af9b stable to default 2013-01-24 13:15:54 +00:00
Emile Joubert f973d137c3 Update copyright 2013 2013-01-23 13:06:40 +00:00
Simon MacMullen 441a099dd0 API change 2013-01-09 12:06:09 +00:00
Simon MacMullen cb693d294a API change 2013-01-09 11:18:44 +00:00
Simon MacMullen fa2818637e Cosmetic 2013-01-08 16:29:04 +00:00
Simon MacMullen 62f7da67ac Use amqp_direct_connection:socket_adapter_info/1. 2013-01-08 16:25:30 +00:00
Simon MacMullen cc685ac724 address -> host. 2012-11-19 16:39:36 +00:00
Emile Joubert 0f30448a51 Use binaries in headers 2012-11-06 10:32:38 +00:00
Emile Joubert 7a10b4a7ec Interoperability fixes 2012-11-05 20:30:45 +00:00
Emile Joubert f574b2dcb6 Authenticate via direct client 2012-09-19 15:34:42 +01:00
Emile Joubert 59e92bc6d8 Preview release build changes 2012-09-12 14:34:41 +01:00
Emile Joubert 2a716fac2b Clearer separation between reader and processor 2012-08-20 17:30:13 +01:00
Emile Joubert a7a58ad66a Updated adapter into record name, safer logging, macro corrections 2012-08-17 15:05:14 +01:00
Emile Joubert a6856a4a04 Improvements around delivery handling 2012-08-16 18:09:21 +01:00
Emile Joubert 37761141cb Name topic translation methods more sensibly 2012-08-16 18:01:45 +01:00
Emile Joubert 8d52799853 Removed adapter info from state 2012-08-16 17:56:50 +01:00
Emile Joubert c55ca8584e Add conservative prefetch limit 2012-08-09 13:52:19 +01:00
Simon MacMullen a225aa3705 Make register not require unregister first. Duplicate detection is now done in the register call. 2012-08-08 13:37:59 +01:00
Emile Joubert d3f4a2dc24 Updates 2012-08-05 23:52:54 +01:00
Emile Joubert 1b9350fe03 Handle QoS1 duplicate publishes 2012-07-16 22:52:53 +01:00
Emile Joubert ec215b34bd Clean sessions, and anonymous connections 2012-07-16 14:57:31 +01:00
Emile Joubert c553880ac7 Avoid a separate erlang process for processor 2012-07-13 16:32:13 +01:00
Emile Joubert f79bf51275 Tests 2012-07-05 18:08:23 +01:00
Emile Joubert 9783db3f5d Rudimentary unsubscribe support 2012-07-04 17:47:07 +01:00
Emile Joubert 78b41c8fc0 Basic subscription and heartbeat response 2012-07-04 16:31:30 +01:00
Emile Joubert 1603079761 Basic authentication and publishing 2012-07-03 17:35:18 +01:00
Emile Joubert f195facf1c Sufficient parsing to accept connection 2012-07-03 09:55:31 +01:00