anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
2,449 Commits 2 Branches 127 Tags
15c2d8f59ea6f8ca33b9867af77822eb71f7a9c5
Commit Graph
2449 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
[email protected] 57137da4bc Added MQTT benchmarking utiliy based on FuseSource MQTT client 2012-08-25 11:40:08 +02:00
andrea 61f0e261bf Forced the TCP closing on DISCONNECT message 2012-08-25 11:32:30 +02:00
andrea ed78372fd0 Defined the IANA MQTT defined port 2012-08-19 17:00:46 +02:00
[email protected] fcc37cc3d2 Added assembly configuration for unique jar creation 2012-08-19 16:36:00 +02:00
andrea d0677f1c44 Added unsubscribe handling to client lib 2012-08-19 12:25:02 +02:00
andrea 4122f1861b Added integration tests to check unsubscribe 2012-08-19 12:24:20 +02:00
andrea f691767fd5 Added unsubscribe management for server side 2012-08-19 12:17:30 +02:00
andrea 54e0b1520d Fixes for remaining length calculation for unsubscribe encoder 2012-08-19 12:16:44 +02:00
andrea 0fb5d8f7a0 Fixed calculation of remaining length bug in Unsubscribe encoder 2012-08-19 11:58:33 +02:00
andrea 34af828653 Refactored reusable code for QoS 1 sending 2012-08-18 17:59:06 +02:00
andrea 96f24bf8d4 Cleaned Client imports 2012-08-18 17:35:50 +02:00
andrea 0c084ec463 Removed commented code 2012-08-18 17:34:53 +02:00
andrea aef6991eb4 Modified client's subscribe to handle adhere to QoS 1 message type and handle retries 2012-08-18 17:33:30 +02:00
andrea 7b0ac3a373 Added trivial messageID generator on client side 2012-08-18 17:31:24 +02:00
andrea 02e9f8dadc Added groovy test script to check multi index 2012-08-18 12:01:13 +02:00
andrea 8cde7e24f2 Re-enabled commented tests 2012-08-18 11:59:31 +02:00
andrea 10e9d4ce37 Fixed serializability of StoredMessage for retained publish messages 2012-08-18 11:59:11 +02:00
selva.andre 2f9931eb6e Temp save 2012-08-15 10:11:22 +02:00
selva.andre e8efbfce42 Bug fix and test to check correct encoding of retain flag 2012-08-14 23:16:55 +02:00
selva.andre 6c8fa400d9 Big fix augment unit testing for retained cases 2012-08-14 22:55:25 +02:00
selva.andre af9fff2911 Added retained messages handling, storage on publish and re-firing (with flag correctly setted) on future subscribe 2012-08-14 22:54:43 +02:00
selva.andre d2a667ef9e Moved creation of messsaging index store from SubscriptionsStore up to SimpleMessaging, to be used also for retained messages 2012-08-14 22:52:53 +02:00
selva.andre 025b5c77ff Fixed implementation for HawtDB storage of subscriptions 2012-08-13 23:42:55 +02:00
selva.andre 389c906d8f Added raw implementation for subscriptions persistence 2012-08-10 23:24:59 +02:00
selva.andre 943a962bb9 Protected the shared variable that maintans binding between active clientID and related IoSessions with lock 2012-08-10 21:32:20 +02:00
selva.andre 8a21aae034 Fixed the clean session to true coming from a previous clean session false 2012-08-10 21:15:26 +02:00
selva.andre bc6189c65e Fixed the clean session once a new connect with an old client ID is re-established 2012-08-10 20:57:36 +02:00
selva.andre 1fcd0290d5 Added integration tests to check cleanSession flag functioning 2012-08-10 19:36:47 +02:00
selva.andre 2dbf10d905 Added to the server's the handling of PING messages 2012-08-10 19:36:14 +02:00
selva.andre 732031a624 Added to the server's MQTTHandler the handling of PINGREQ message 2012-08-10 19:35:43 +02:00
selva.andre 8e3f83403f Added to the server's MQTTHandler the handleing of DISCONNECT message 2012-08-10 19:31:14 +02:00
selva.andre 5be34ec932 Modified the subscriptions storage to removed the subscriptions for a certain clientID 2012-08-10 19:30:07 +02:00
selva.andre e15e5721fb Modified Client to: 
- accept a user provided clientID in the constructor
 - handle the cleanSession in connect method
 - let the user register a collback to a topic without do any subscription on server side
 - divide the closing from a server from the shutdown of all the client instance
 2012-08-10 19:23:23 +02:00
selva.andre a0139317e8 Modified Server to gracefully terminate on stopServer 2012-08-10 19:17:24 +02:00
selva.andre 50724aa7fd Minor change 2012-08-09 23:19:07 +02:00
selva.andre 5540805570 Added Client ID generator 2012-08-09 23:14:29 +02:00
selva.andre 937a7b7060 Fixed timer for Ping requests 2012-08-09 22:40:23 +02:00
selva.andre 343f36c4f5 Added cyclic ping request thread. 2012-08-08 23:31:26 +02:00
selva.andre c1af1d9c31 Removed unused imports 2012-08-08 21:56:22 +02:00
selva.andre 1173406b0a Fixed matching multi topic and single selector 2012-08-08 21:52:18 +02:00
selva.andre 2ec0c76ba2 First attempt for matching multi topic selector 2012-08-08 21:26:35 +02:00
selva.andre 372af61076 Fixed the matching of topic with multi selector 2012-08-07 23:38:32 +02:00
selva.andre b9d4356487 Minor change, renamed an inner field 2012-08-07 22:20:20 +02:00
selva.andre fdedfecfba Added first implementation for topic tree subscriptions. 2012-08-07 00:17:47 +02:00
selva.andre f8d75bf004 Added topic + sign parsing for single level wildcard 2012-08-06 22:53:56 +02:00
andsel bf1db7b207 Fixed tokenization to handle multi-level sign 2012-08-03 17:34:16 +02:00
andsel 3be3f614c2 Added check of not empty subtopics in splitTopics method 2012-08-03 17:21:16 +02:00
andsel c54b35c79c Introduced trivial tokenization of topic 2012-08-03 17:08:18 +02:00
andsel 279b16fd26 Merge branch 'topic_tree_move' 2012-08-03 16:33:04 +02:00
andsel 03ff484702 Merge branch 'master' into topic_tree_move 2012-08-03 16:32:35 +02:00