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

422 Commity (2d5d1c3d4510b51c93b58dabed01960ffa8249e2)

Autor SHA1 Wiadomość Data
Nicolas Jouanin fd6ed3c42c Fix error handling if broker can't be connected 
HBMQTT-24
 2015-08-12 18:46:56 +02:00
Nicolas Jouanin 74a66632cf connect() method returns a Future which has result set if the session is disconnected from the broker. 2015-08-11 22:20:03 +02:00
Nicolas Jouanin 1e563ee257 Move writer.close() after writer_coro is done 2015-08-11 22:15:02 +02:00
Nicolas Jouanin 92a2b50a8c Rename transitions machine 2015-08-11 21:07:38 +02:00
Nicolas Jouanin 0077c61943 Test client reconnection (and messages buffering while connection lost) 2015-08-10 23:17:22 +02:00
Nicolas Jouanin b14cd1b5a4 Close writer sooner on handler stop to stop reader_coro 2015-08-10 22:05:30 +02:00
Nicolas Jouanin 43de5e4b4c Remove verbose debug messages 2015-08-10 22:05:03 +02:00
Nicolas Jouanin b1cb963ece Merge branch 'feature/dollar_sys' into develop 
HBMQTT-11
 2015-08-10 21:31:45 +02:00
Nicolas Jouanin 4d5074aced Implement basic $SYS tree 2015-08-10 21:30:03 +02:00
Nicolas Jouanin 83ab0c318a Add message count properties 2015-08-10 21:29:40 +02:00
Nicolas Jouanin bc248f9fc5 Move debug trace to get packet length 2015-08-09 23:19:17 +02:00
Nicolas Jouanin 592952f1f0 Add first $SYS topics 2015-08-09 23:07:55 +02:00
Nicolas Jouanin 568bdd9cb3 Fix client session initialisation 2015-08-09 23:00:30 +02:00
Nicolas Jouanin 986046b80b Fix clean_session init 2015-08-09 22:58:09 +02:00
Nicolas Jouanin 4a5a702cf8 Clean warnings 2015-08-09 17:48:47 +02:00
Nicolas Jouanin c8705a059f Add packet sent/received signals 2015-08-08 22:04:55 +02:00
Nicolas Jouanin 1fc3d5094d Fix formatting 2015-08-08 22:04:17 +02:00
Nicolas Jouanin afed8acf72 Generate packet ID only for QOS > 0 messages. 2015-08-08 22:01:08 +02:00
Nicolas Jouanin 9adbbdfc3a Remove unused 2015-08-08 13:58:21 +02:00
Nicolas Jouanin 73a7395257 Add $SYS publish on 10s interval 2015-08-08 13:57:48 +02:00
Nicolas Jouanin 7b5145da72 Add to_bytes() method on Packet 2015-08-08 13:57:17 +02:00
Nicolas Jouanin a87d989553 Listeners accept max_connections parameters 
Server manage connection count through semaphore
HBMQTT-23
 2015-08-06 22:44:37 +02:00
Nicolas Jouanin 635eea30b3 Merge branch 'feature/support_ssl' into develop 
HBMQTT-20
HBMQTT-21
 2015-08-06 21:10:21 +02:00
Nicolas Jouanin 9428accbf7 Add samples for SSL and WS 2015-08-06 21:08:22 +02:00
Nicolas Jouanin 901574f2da Add client certificate load 2015-08-06 21:07:44 +02:00
Nicolas Jouanin 67d2f4e7ce clean 2015-08-03 11:40:27 +02:00
Nicolas Jouanin 2bfc70eebf SSL fixes 2015-08-02 23:37:49 +02:00
Nicolas Jouanin b9f944f6cc randomize gen_client_id 2015-08-02 23:37:16 +02:00
Nicolas Jouanin 103f7e8419 Add SSL connect to WS connection 2015-08-02 17:09:55 +02:00
Nicolas Jouanin 9d0ee85497 Refactor client connect() method to accept a single uri argument 2015-08-02 16:56:50 +02:00
Nicolas Jouanin 9a7ca67097 Fix testing 2015-08-02 16:05:24 +02:00
Nicolas Jouanin c0b800f419 Add WS support on client 2015-08-02 16:01:16 +02:00
Nicolas Jouanin 737cb53b90 Move reserved packet management to handler. 2015-08-02 16:00:57 +02:00
Nicolas Jouanin 7ecf802e2d Fix buffer management when feeding 2015-08-02 15:59:54 +02:00
Nicolas Jouanin 673dd9f293 add capath, cadata attributes to SSL context 2015-08-02 13:46:35 +02:00
Nicolas Jouanin 09d7a89621 Fix exception catching on connect error 2015-08-02 13:37:30 +02:00
Nicolas Jouanin fddb0a3d13 Support encrypted (TLS) connection on client 2015-08-01 23:04:30 +02:00
Nicolas Jouanin e8cda5ca51 Remove unused imports 2015-08-01 22:21:06 +02:00
Nicolas Jouanin 8d33a38901 Manage reader/writer adapters inside broker (test passing) 2015-08-01 22:16:39 +02:00
Nicolas Jouanin 771469a582 fix to_bytes 2015-08-01 22:16:11 +02:00
Nicolas Jouanin db5a9fd5d1 add get_peer_info() and close() coroutines 2015-08-01 22:15:56 +02:00
Nicolas Jouanin bdb0f2e4e5 Fix returned code after enum remove 2015-08-01 21:51:59 +02:00
Nicolas Jouanin a3df055f34 return None if EOF received 2015-08-01 21:51:37 +02:00
Nicolas Jouanin dd19fbb511 Manage reader,writer in handler 2015-08-01 21:51:20 +02:00
Nicolas Jouanin 77a96faeeb Correct class name 2015-08-01 21:50:52 +02:00
Nicolas Jouanin e85e319597 Refactor mutt classes for using adapters 2015-07-31 23:01:32 +02:00
Nicolas Jouanin 3185747f09 Split read/write adapters 2015-07-30 22:50:41 +02:00
Nicolas Jouanin 5166236645 Add network protocol adapter + begin Packet refactoring 2015-07-29 23:37:39 +02:00
Nicolas Jouanin 276edb5210 Add websockets requirement 2015-07-29 23:36:54 +02:00
Nicolas Jouanin 5828011463 Add sample configuration expected for listeners 2015-07-27 23:11:54 +02:00