mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność
865 Commity
16 Gałęzie
13 Tagi
10 MiB
Wykres commitów

560 Commity (pre-commit)

Autor SHA1 Wiadomość Data
Nicolas cd58d1dabc Fix #60 2017-06-02 21:41:17 +02:00
Nicolas 0dbef5005a Fix #74 
set_exception only for not done tasks.
 2017-06-02 21:37:10 +02:00
Nicolas 7ff3451b94 Merge branch 'master' of https://github.com/beerfactory/hbmqtt 2017-06-02 21:17:26 +02:00
Nicolas 2c1db79127 Fix #75. 
Reset packet_id when > 65535.
This may lead to performance problem when there are still many in-flight messages (QOS1 or QOS 2 not yet acknowledged)
 2017-06-02 21:17:05 +02:00
Guillaume Desvé 575118cc27 Remove plugin manager _fired_events listcomp 2017-05-05 17:42:04 +02:00
dansheme 605747723d fixed issues while using non default async loop 2017-03-12 15:50:28 +02:00
Nicolas d2bf2a77b4 Bump version 2016-11-27 20:56:09 +01:00
Nicolas 7d9739427a release 2016-11-27 20:53:03 +01:00
Chifeng Chou 488ff01041 release PluginManager._fired_events if they are done 2016-11-17 12:28:09 +08:00
cfchou 5a2830b6f8 disables verification of the server hostname in the server certificate 2016-09-22 16:39:14 +08:00
Florian Ludwig f88d87fc60 accept boolean as config argument for "ssl" 2016-07-30 21:17:57 +02:00
Nicolas a0cb5f5009 Add some checking for invalid port value (see issue #42) 2016-06-10 21:30:05 +02:00
Nicolas f9ed86869c Fix version 2016-05-31 22:30:57 +02:00
Nicolas c6a8961409 Fix version 2016-05-31 22:30:07 +02:00
Nicolas 55a4ac650c Version 2016-05-31 22:27:47 +02:00
Nicolas e368125049 bump version 2016-05-31 22:26:18 +02:00
Nicolas 8e09e36858 update version 2016-05-31 22:02:45 +02:00
Nicolas 9f61197cdd Fix #41 
Use direct match if topic filter doen't contain wildcard chars
 2016-05-31 21:56:46 +02:00
Nicolas b7401443c8 Fix #40 and add test cases 2016-05-31 21:40:10 +02:00
Nicolas da269d45e8 Change message level logged when clean session is set but the session to delete is not found. 2016-05-19 21:18:57 +02:00
Nicolas 62521a595a bump version 2016-05-07 07:27:55 +02:00
Nicolas ccb742a0b0 bump version 2016-05-07 07:24:54 +02:00
Nicolas faadefb953 Fix #37 
$SYS/broker root was duplicated when broadcasting messages
 2016-05-07 07:16:37 +02:00
Nicolas 075522b190 Bump to next version 2016-05-04 23:11:02 +02:00
Nicolas 966f82047c Bump version 2016-05-04 23:02:48 +02:00
Nicolas f298a4a543 Fix #35 
Test retain message exists before trying to delete it.
 2016-05-04 22:43:06 +02:00
Nicolas 0e11d545d8 Fix #23 
+ add test case
 2016-05-04 22:35:38 +02:00
Nicolas 13c4a8a09f Fix #36 
Don't start listener if it doesn't contain a 'bind' parameter
 2016-05-04 21:33:01 +02:00
Nicolas 6f7b438ebf Refactor scripts utils location 2016-05-04 21:32:01 +02:00
Nicolas ae7d13af82 Fix #31 2016-04-10 23:10:11 +02:00
Nicolas 8c3cd9be2a Fix #34 2016-04-10 23:05:42 +02:00
Nicolas e9b806348e Fix #32 2016-04-10 23:02:10 +02:00
Nicolas ea62725868 Fix #30 2016-04-10 22:32:07 +02:00
Nicolas e391ccebaf Fix #27 2016-04-10 22:17:28 +02:00
Nicolas 5dc5293063 Fix #25 #26 2016-04-10 22:15:17 +02:00
Nicolas 360d5b03c7 Fix #28 2016-04-10 22:06:33 +02:00
Nicolas dd04b44a57 Fix timeout management on message delivery 2016-04-10 21:46:52 +02:00
Nicolas 7a868bd66e Fix issue #24 
Data was not read correctly until the end of the buffer
 2016-04-10 15:33:48 +02:00
Nicolas d380029cb5 Fix typo 2016-04-06 14:33:13 +02:00
njouanin 3fa35849e0 Bump version 2016-03-12 22:02:34 +01:00
njouanin dbe3e76024 Bump version 2016-03-12 21:54:58 +01:00
njouanin ba09225779 Fix issue #22 2016-03-08 21:10:46 +01:00
njouanin f2caf70927 Bump version 2016-03-06 21:57:52 +01:00
njouanin 8c32cb308f Bump version 2016-03-06 21:53:22 +01:00
njouanin 6906e7ebe2 Upgrade websockets to 3.0.0 2016-03-06 21:41:17 +01:00
njouanin ac04185e31 Merge branch 'master' of https://github.com/beerfactory/hbmqtt into develop 2016-03-06 21:39:47 +01:00
pumelo 0064c500ac Add subprotocol headers for ws connection as defined by the mqtt specification v3.1.1 chapter 6: 
''The WebSocket Sub Protocol name selected and returned by the server MUST be “mqtt” [MQTT-6.0.0-4]."
 2016-03-04 22:52:18 +01:00
njouanin bdd8fb30ab Bump version 2016-02-05 21:21:36 +01:00
njouanin 8bd897bff5 Bump version 2016-02-05 21:11:21 +01:00
njouanin 5458ec7764 No need to close stream when client has disconnected (it is already closed). 
Fixes issue #19
 2016-02-05 14:14:57 +01:00
Nico 2cbe53635f Bump develop version 2015-11-13 22:18:08 +01:00
Nico 8f86d94964 Bump version 2015-11-13 22:13:09 +01:00
Nico 82985b6f1c Improve documentation 2015-11-13 22:07:58 +01:00
Nico 35c48ff9a8 Improve documentation 2015-11-12 22:57:00 +01:00
Nico 6c0657b438 Documentation update 2015-11-11 22:40:38 +01:00
Nico 263d86f942 Docstring 2015-11-08 20:46:58 +01:00
Nico d71b9c1483 Fix toc and add missing documents 2015-11-06 23:02:19 +01:00
Nico 31734ce28f Add missing import 2015-11-05 21:53:10 +01:00
Nico c4e58669e9 Fix task cleanup when connection closed 2015-11-04 22:11:13 +01:00
Nico 7bf2419862 Remove unused future 2015-11-02 23:56:10 +01:00
Chris Laws 8f729cfdbc Fix ping issue 2015-11-02 23:05:37 +10:30
Nico ecd793b82d Add additional test before reporting error 2015-11-01 22:33:12 +01:00
Nico dd1a5bde6a Randomize packet ID 2015-11-01 21:55:24 +01:00
Nico 8dab60a444 Add support for both Python 3.4 and 3.5 2015-11-01 21:27:33 +01:00
Nico 4dcf8eb477 Revert to 3.4 coroutine syntax 2015-11-01 15:58:20 +01:00
Nico 36c086df30 Various fixes 2015-11-01 14:23:00 +01:00
Nico 6daa752800 Add message type to exception 2015-11-01 14:22:31 +01:00
Nico 3d38ce4bce FIX string decoding 2015-11-01 14:21:34 +01:00
Nico 240d26f48b change logging level 2015-10-31 14:28:54 +01:00
Nico daf53b83a5 Fix assert position 2015-10-31 14:28:41 +01:00
Nico a8e5879551 Remove blinker signal 
Add some debugging info
 2015-10-20 21:53:21 +02:00
Nico e6c7c4d3cb Implement $SYS topics as broker plugin 2015-10-19 21:37:31 +02:00
Nico 52e3160995 #HBMQTT-35 
Refactor yield from -> await
 2015-10-16 22:13:37 +02:00
Nico 6a876be559 Improve perf 2015-10-15 21:57:21 +02:00
Nico 7ede67ed7e Performance 2015-10-14 22:58:18 +02:00
Nico b983de1c01 HBMQTT-42 
Make broadcasting asynchronous
 2015-10-12 22:42:22 +02:00
Nico 6da03d9913 Make use of ac_timeout parameter 2015-10-12 21:48:45 +02:00
Nico c3a144c6a3 All tests passing 2015-10-12 21:33:14 +02:00
Nico b6bd91e3fb Fix 2015-10-11 15:10:23 +02:00
Nico a3d856b4c8 fixes + add tests 2015-10-10 22:25:31 +02:00
Nico d1a5cdc2c1 fix result 2015-10-10 22:25:13 +02:00
Nico 6b7b962b16 Add publish retain test 2015-10-10 15:01:17 +02:00
Nico a456d9cf21 Fix QOS flag init + add tests 2015-10-10 14:42:49 +02:00
Nico 10a0ef797b Add unsubscribe test 
Add subscribe twice on same topic test
 2015-10-08 22:38:32 +02:00
Nico c0190fafeb Add subscription test 2015-10-08 22:09:34 +02:00
Nico d0491a92ef add test assertions 2015-10-08 21:25:15 +02:00
Nico 3acec1d606 Add broker test class + fixes in both client and broker connection management 2015-10-07 22:42:04 +02:00
Nico 58e6069656 Fix 2015-10-07 21:24:08 +02:00
Nico 1366e53167 Ensure draining on close 2015-10-07 21:23:57 +02:00
Nico 53b7168c1c Forgot to return return_code 2015-10-03 21:46:52 +02:00
Nico 1f7341ac79 conform to new API 2015-09-30 22:58:54 +02:00
Nico 17fd361c31 Fix typo 2015-09-30 22:54:10 +02:00
Nico 6005ca1d79 Allow broker creator to provide a custom plugin namespace (useful for testing) 2015-09-30 22:41:07 +02:00
Nico fb760e6858 Add missing 'from' 2015-09-30 21:33:42 +02:00
Nico a4e002de2a Add publish message retry on start() 2015-09-30 21:22:46 +02:00
Nico 44640a64f6 MQTTClient coroutine are now decorated with a wait connected event 2015-09-29 22:19:20 +02:00
Nico 20a43e5b25 Refactored client connection 
allow auto-reconnect
 2015-09-29 21:54:09 +02:00
Nico 32c7c7242d Add attach_session() detach_session() methods. (will be used for reconnection handling) 2015-09-28 22:51:18 +02:00
Nico fdf83b912f replace deprecated calls to warn() 2015-09-27 22:06:27 +02:00
Nico 464fa81a81 Remove obsolete files 2015-09-27 21:48:42 +02:00
Nico 5e889f5059 Ignore writer.close() error on handler stop 2015-09-27 21:39:17 +02:00
Nico cbf86e9605 remove unused 2015-09-27 21:17:28 +02:00
Nico 8bafbeb0f2 remove unused 2015-09-27 21:17:12 +02:00
Nico 01628e25a6 Fix port init. 2015-09-27 21:16:55 +02:00
Nico cecf88c2c9 Manage already done handler (shouldn't happen) 2015-09-23 21:55:35 +02:00
Nico e85838512e code cleanup 2015-09-23 21:25:26 +02:00
Nico 13b1d17b01 Python 3.4 compatibility 2015-09-23 21:17:44 +02:00
Nico 0b5fa53152 Add debug message 2015-09-22 22:44:06 +02:00
Nico c05aee5468 Fix tests except QOS2 receive 2015-09-21 23:05:35 +02:00
Nico 7998824ef4 run message handling async for not blocking the messages reception 2015-09-16 22:17:56 +02:00
Nico 7954ac4f0a Forgot message delivery 2015-09-16 22:17:21 +02:00
Nico 417bb01148 Receive messages FIX 2015-09-15 23:17:55 +02:00
Nico 4b7be2b879 Add QOS1 message test and fix 2015-09-15 21:47:42 +02:00
Nico 2d5d1c3d45 Add and fix QOS_0 message receive 2015-09-15 21:31:07 +02:00
Nico 2c60b3c1a0 Commit with test failure 2015-09-13 22:36:22 +02:00
Nico cf9e78e4bb move stop() method 2015-09-12 15:54:18 +02:00
Nico a5c34ed315 BufferWriter uses provided buffer 2015-09-12 15:28:05 +02:00
Nicolas Jouanin e3ac527924 implement QOS_2 handling 2015-09-12 14:16:22 +02:00
Nicolas Jouanin 9fe5e4e851 Remove unused 2015-09-12 14:15:59 +02:00
Nicolas Jouanin b4ffdf482a Fix tuple usage 2015-09-12 14:15:44 +02:00
Nicolas Jouanin 586b898c63 Remove writer coro + WIP for publish message protocol flow management 2015-09-11 22:39:47 +02:00
nico 785d363b2f Refactoring WIP 2015-09-11 13:54:14 +02:00
Nicolas Jouanin 2f3c143554 Refactor publish message sent acknowledgment management 2015-09-10 22:41:54 +02:00
Nicolas Jouanin 3c656ef95b remove state machine 2015-09-10 22:40:49 +02:00
Nicolas Jouanin 8d20a3d95d Remove unused test and add return value to publish() 2015-09-10 22:40:30 +02:00
Nicolas Jouanin a1c8655463 Change use of deprecated method 2015-09-10 21:34:45 +02:00
Nicolas Jouanin 866321ad22 Use OrderedDict implementation so list is iterated in the same order the elements were added 2015-09-10 21:34:18 +02:00
Nicolas Jouanin 8b3ca8cbbe add protocol_ts attribute which is initialized to current timestamp when a packet is read or written to the network. This is known as the protocol timestamp 2015-09-10 21:33:34 +02:00
nico 9996b289ff Add LoggingAdapter 2015-09-10 14:01:53 +02:00
nico a6f19c909b remove coroutine declaration for check_connect 2015-09-10 14:01:28 +02:00
nico beb3fd4400 Fix missing plugin call 2015-09-10 13:32:08 +02:00
Nicolas Jouanin 0cbbaa6763 Refactoring WIP 2015-09-09 23:01:11 +02:00
Nicolas Jouanin 5d6732b1ac remove packet_type from repr() as given by the class name 2015-09-09 22:29:55 +02:00
nico 008b99b5a4 Begin publish message management refactoring 2015-09-09 14:22:32 +02:00
nico 15468b7849 Improve handler stopping (remove wait delay when disconnecting) 2015-09-08 15:01:37 +02:00
nico 29cb2600f3 HBMQTT-34 
Rewrite URI when using websocket to remove username and password from netloc.
 2015-09-08 14:19:40 +02:00
Nicolas Jouanin 60cc2da745 Refactoring 2015-09-06 22:23:06 +02:00
Nicolas Jouanin a8c88b98af Refactoring 2015-09-03 22:20:31 +02:00
Nicolas Jouanin c3dc01daf3 Merge branch 'develop' of https://github.com/beerfactory/hbmqtt into develop 2015-09-03 21:26:44 +02:00
nico 7b79f56199 Add a method to facilitate access to packet data structure. 2015-09-03 16:48:11 +02:00
Nicolas Jouanin 313c4a367a Remove useless Task creation 2015-09-02 22:41:24 +02:00
Nicolas Jouanin fb6c2784bb rename waiters 2015-09-01 22:53:17 +02:00
Nicolas Jouanin bcf14ef6b8 subscription refactoring 2015-09-01 22:42:23 +02:00
Nicolas Jouanin 7df739acfe add persistence sample 2015-09-01 21:24:42 +02:00
Nicolas Jouanin 9dc217cf82 Add persistence plugin (WIP) 2015-08-31 22:37:01 +02:00
Nicolas Jouanin c8e0a4e356 Allow to filter auth plugins 2015-08-29 22:10:28 +02:00
Nicolas Jouanin 61cdc1a0d2 Implement anonymous and file auth plugin 
HBMQTT-14
 2015-08-29 21:25:59 +02:00
Nicolas Jouanin 15cea7e9fa Fix exception when connection is refused 2015-08-29 21:19:38 +02:00
Nicolas Jouanin 6e69726da8 Doc 2015-08-29 15:30:05 +02:00
Nicolas Jouanin d0e32610bd Add file auth plugin 2015-08-29 15:29:09 +02:00