Commit Graph

1430 Commits

Author SHA1 Message Date
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
Simon MacMullen d0f045bf1f Eliminate use of gen_server:call/2. 2013-10-24 12:22:34 +01:00
Simon MacMullen 9bde9ce822 Revert part of f438760bff27 since the exception is now an IOException. 2013-10-03 11:34:09 +01: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
Alvaro Videla e2c9f63d0c updated README to point to /mqtt.html 2013-08-19 09:14:52 -06:00
Emile Joubert 50f162ea0d Swap connect and setting callback 2013-07-31 15:28:22 +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 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
Tim Watson c95996d80a merge bug25487 into default 2013-04-05 13:32:59 +01:00
Emile Joubert ed3ee2a2ff client_sup API change 2013-04-05 12:42:32 +01:00
Emile Joubert f225804df5 Transplant reverse of 8c13f168cf00 2013-04-04 17:08:30 +01:00
Emile Joubert 809fa199ca Unfix bug 2013-04-04 16:41:57 +01:00
Emile Joubert 2e74c028c0 client_sup API change 2013-04-04 16:41:20 +01:00
Emile Joubert 1617d8c66d Propagate API change of rabbit_client_sup 2013-03-14 16:13:03 +00:00
Emile Joubert 93dbe20ede Correct use of client_id and worker 2013-03-13 16:11:08 +00:00
Emile Joubert bd0f6f11ff Handle connection abort while opening more gracefully 2013-03-01 10:49:23 +00:00
Matthias Radestock 5eb96838ab merge stable into default 2013-02-28 13:08:55 +00:00
Emile Joubert ffbe2c6560 Hibernate after opening connection and when waiting for data 2013-02-28 13:04:59 +00:00
Matthias Radestock 3458e1ab3e cosmetic 2013-02-28 12:27:23 +00:00
Emile Joubert cc5259ea9c Silence warnings 2013-02-27 11:01:09 +00:00
Matthias Radestock e97b07fa0f socket buffer size tuning has moved into the tcp_acceptor 2013-02-26 15:33:13 +00: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
Simon MacMullen 0be8fc79af Establish stable branch 2012-11-19 16:37:20 +00:00
Emile Joubert ad7d5bdbf0 Turn off file-based client persistence in tests 2012-11-13 11:30:17 +00:00
Emile Joubert 44d9fa8b17 Tests require Java AMQP 2012-11-12 13:35:35 +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 b88a0e3373 Increase test delay 2012-09-25 09:52:41 +01:00
Simon MacMullen 43bd7f0188 Merge bug25089 2012-09-21 15:07:35 +01:00
Simon MacMullen 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
Emile Joubert f574b2dcb6 Authenticate via direct client 2012-09-19 15:34:42 +01:00
Emile Joubert 11c2e485ec Prefer https to git protocol for firewall reasons 2012-09-17 15:37:02 +01:00
Emile Joubert 03dc8b5849 Make tests run from umbrella and pass more reliably 2012-09-17 14:57:31 +01:00
Emile Joubert 2812742f8e Correct log method 2012-09-12 16:28:24 +01:00
Simon MacMullen 0a53188d37 Typo 2012-09-12 14:37:45 +01:00
Emile Joubert 59e92bc6d8 Preview release build changes 2012-09-12 14:34:41 +01:00
Emile Joubert a19130be7f Document configuration 2012-09-12 12:18:39 +01:00
Emile Joubert cfcdf7a59b More consistent naming of credit flow state 2012-08-21 16:45:14 +01:00
Emile Joubert c3801689b2 Backout changeset 641cfc6d09b7 2012-08-21 16:38:14 +01:00
Emile Joubert 13a61caab4 Remove unnecessary configuration 2012-08-21 16:22:31 +01:00
Emile Joubert 2a716fac2b Clearer separation between reader and processor 2012-08-20 17:30:13 +01:00
Emile Joubert d24a5d7f2a Register collector name differently 2012-08-17 15:14:40 +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 a53c389211 Remove implicit rules for compiling java 2012-08-10 10:16:15 +01:00
Emile Joubert c904f78b2e Run tests from Makefile 2012-08-09 18:55:45 +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
Simon MacMullen 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
Simon MacMullen 85727eafc7 Seems a bit cleaner to ignore undefined here. 2012-08-08 13:09:50 +01:00
Simon MacMullen 75620477ab Simplify 2012-08-08 12:49:53 +01:00
Simon MacMullen 1eef766311 Remove that {go, ...} gs call. 2012-08-08 12:47:24 +01:00
Emile Joubert 02f375a3c0 Add client id collector 2012-08-06 17:58:15 +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
Emile Joubert e973267fcf Protocol adapter skeleton 2012-06-26 17:57:24 +01:00