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
erics465 ced07f90dd
added passthrough of websocket extra headers 2018-11-20 12:42:49 +01:00
Yves Delley bffed55a17 do actually wait for the connection in the mqtt_connection decorator 2018-11-13 17:56:59 +01:00
Nicolas 7704170d1d
Bump to next version 2018-11-11 12:09:50 +01:00
Nicolas 3c2c5d6338
Release version 2018-11-09 18:18:45 +01:00
Nicolas 89dc31ce36
Merge pull request #150 from luchermans/patch-1 
Update topic_checking.py
 2018-11-07 13:34:53 +01:00
Thinh Nguyen 5a241d7739 Only setting session username/password if it is not already set. This is to prevent failures when the broker is reconnecting without username/password 2018-10-29 13:55:09 +11:00
luchermans 577ec3cf0e
Update topic_checking.py 
remove if session.username when using anonymous client
 2018-10-03 15:42:49 +02:00
Richard Kojedzinszky deeae6a230 MQTTClient: init should not overwrite global defaults 2018-09-22 14:28:31 +02:00
Nicolas 776c2992b6
Bump version 2018-07-21 21:57:51 +02:00
Nicolas bc837c80bc
Release v0.9.4 2018-07-21 21:50:28 +02:00
Nicolas 8a0a1ad18e
bump version 2018-07-16 21:15:58 +02:00
Nicolas ccfa6b7319
Version 0.9.3 2018-07-16 21:09:44 +02:00
Nicolas 1af9e7f99c
Merge pull request #139 from gdraynz/py37 
python3.7 support
 2018-07-16 21:06:44 +02:00
Aleksandr Mironov 0f17486e13 Pass CA params to broker's SSL context 2018-07-12 11:16:51 +03:00
Richard Kojedzinszky 44479b73b9 Handle no more reconnect case in mqtt_connected decorator 
Fixes #140
 2018-07-05 21:29:07 +02:00
Guillaume Desvé 31888f8e69 python3.7 support 2018-06-29 15:56:27 +02:00
krh 75a85d1ea4 Import InvalidHandshake from 'websockets.exceptions' not 'websockets.handshake', since websockets 5.0 no longer provides that alias. 2018-05-22 11:28:43 -07:00
Nicolas 7c8e393166
Merge pull request #114 from phooky/master 
Correctly handle CONNECT with zero-length client_id
 2018-04-29 17:30:02 +02:00
Román Cárdenas 59f9d28029 Added topic filtering Plugin 2018-03-19 10:58:56 +01:00
Román Cárdenas 42143a196c Client authentication error fixed 2018-03-16 15:27:31 +01:00
Adam Mayer bbcf7b3849
correctly handle CONNECT with zero-length client_id 
Zero-length client_ids in CONNECT packets show up in the payload as empty strings, not None; the broker should generate a new id for these connections.
 2018-03-14 13:21:17 -04:00
Nicolas 031580a3fc
Bump version 2018-03-07 12:09:51 +01:00
Nicolas 39cc93cfee
0.9.2 release 2018-03-07 09:52:18 +01:00
Vegard Storheil Eriksen 7df731790a Re-raise exception from deliver_task in MQTTClient.deliver_message(). 
deliver_task will raise a ClientException to signal a connection loss.
Passing it on to the caller instead of silently ignoring it lets the
caller handle the connection loss. Exiting the function early also
avoids an IndexError when trying to pop from client_tasks.

Fixes #106
 2018-02-13 23:58:48 +01:00
mi3z 47e37404fd TLS connections can be established by default with system certificates to publish domains (for example to 'mqtts://iot.eclipse.org') - the client only requires cafiles if the broker provides self signed certificates 2017-11-22 10:40:20 +01:00
mi3z 05b86e2f1e fixed flake8 typo 2017-11-15 11:08:14 +01:00
mi3z 86c0726133 fixed Bug Test 'test_client_connect_clean_session_false' by adding a additional variable 'client_id_is_random'. This allows to determine if a client_id is generated by the broker and therefore to disallows a client connection with the clean_session flag set to 0 2017-11-14 18:51:21 +01:00
Nicolas 059baa78bf
Merge pull request #91 from mi3z/master 
fixed #78
 2017-11-10 14:22:41 +01:00
alex 84082b1f58 Fix occasional exception while processing another exception. 2017-11-05 00:20:57 -07:00
Jan Vlcinsky fac2c6ea52 Fix issue #95 Randomly incomplete topic name in consuming from MQTT topic. 2017-10-30 17:33:41 +01:00
mi3z cf5472f4c9 fixed #78 
fixed Error in zero length client id when using 3.1.1 #78
 2017-10-23 16:04:26 +02:00
Nguyễn Hồng Quân 04098b7ba8 Fix the Client doc 2017-10-18 17:54:19 +07:00
Nico 810766d27f Bump version 2017-10-12 18:57:57 +02:00
Nico b8fc1700a3 Release 2017-10-12 18:45:34 +02:00
Guillaume Desvé 3fe4bacf02 Fix missing positional argument on 'cancel_tasks' 2017-10-10 16:19:37 +02:00
Guillaume Desvé 90a9344068 Add __slots__ attribute to the most used classes 2017-10-10 16:09:55 +02:00
Stein Magnus Jodal ce4824bf70 flake8: Fix all F841 unused local variable warnings 2017-08-07 01:23:21 +02:00
Stein Magnus Jodal 559c18f681 flake8: Fix all F403, F405, F821 import warnings 2017-08-07 01:23:21 +02:00
Stein Magnus Jodal 6435e4239c flake8: Fix all F401 unused imports warnings 2017-08-07 01:23:21 +02:00
Stein Magnus Jodal 1b5ead2e08 flake8: Fix all E402 import warnings 2017-08-07 01:23:21 +02:00
Stein Magnus Jodal 177bfb627c flake8: Fix all E1xx indentation warnings 2017-08-07 01:23:21 +02:00
Stein Magnus Jodal ed676945b4 flake8: Fix all Wxxx whitespace and newline warnings 2017-08-07 01:23:21 +02:00
Stein Magnus Jodal df2c9b8a43 flake8: Fix all E3xx newline warnings 2017-08-07 01:23:20 +02:00
Stein Magnus Jodal 6f4b306886 flake8: Fix all E2xx whitespace warnings 2017-08-07 01:23:20 +02:00
Stein Magnus Jodal 8d414355ed Merge branch 'master' into transitions-0.5 2017-08-06 08:52:39 +02:00
Stein Magnus Jodal d3a6d9d759 Support transitions >= 0.5.0 
transitions 0.5.0 replaced MachineError with ValueError and
AttributeError for exceptions raised when transitioning the state
machine. MachineError is still available in transitions 0.5.0, so we
catch both MachineError and the relevant new exception to work with
both old and new versions of transitions.
 2017-07-26 14:49:02 +02:00
Stein Magnus Jodal a89e744a47 Change deprecated warn() to warning() 2017-07-26 14:06:17 +02:00
Trevor Joynson (trevorj) f7d84737f9 Fix delicious exception so it is properly eaten 2017-07-06 17:37:24 -07:00
Nicolas 32720ca373 Bump version 2017-06-02 21:53:10 +02:00
Nicolas 2bdb0016d7 Release 2017-06-02 21:48:49 +02:00
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