 andrea
|
016d7e8926
|
Moved testCleanSession_maintainClientSubscriptions from custome API to Fuse's
|
2013-08-28 20:14:55 +02:00 |
|
|
andrea
|
2cc1878cd6
|
Moved Fuse client source from asynch to sycnh API
|
2013-08-28 20:12:09 +02:00 |
|
|
andrea
|
81b4c3fb8d
|
Missed in previous bump
|
2013-08-28 18:31:51 +02:00 |
|
|
andrea
|
76a889f160
|
Bumped version 0.2
|
2013-08-28 18:18:28 +02:00 |
|
|
andrea
|
a8758b7f04
|
Fixed interdependency failure between SimpleMessagingTest and ServerIntegrationTest
|
2013-08-28 18:14:51 +02:00 |
|
|
andrea
|
2259c115c4
|
Introduced BFS utility method to be used to do a deep clean in subscriptions tree, and to implement an utility tree dump method
|
2013-08-28 18:14:09 +02:00 |
|
|
andrea
|
54af962ea3
|
Introduced practical toString method
|
2013-08-28 17:56:06 +02:00 |
|
|
andrea
|
53cb3dda73
|
Modified Server class to be embedded, fixes #10 and #11
|
2013-08-28 10:36:28 +02:00 |
|
|
andrea
|
a010371a8b
|
Removed unused method
|
2013-08-28 10:26:23 +02:00 |
|
|
andrea
|
afcc20f483
|
Added unit test and fix for issue #12, due to bad topic in publish message after a late subscription and messages retained in DB.
|
2013-08-28 10:26:02 +02:00 |
|
|
andrea
|
b1ee353ea8
|
Minor change, moved the test files into correct folders
|
2013-08-27 18:03:52 +02:00 |
|
|
andrea
|
4037a0c0b0
|
Minor change, minor readability improve
|
2013-08-27 16:24:11 +02:00 |
|
|
selva.andre
|
2cc474dd26
|
Merge branch 'master' of https://code.google.com/p/moquette-mqtt
|
2012-09-17 11:52:20 +02:00 |
|
|
andrea
|
9df2669839
|
Fixed issue 5, was due to bad read timeout management in IoSession.idle.
|
2012-09-17 11:29:13 +02:00 |
|
|
andrea
|
ecea97f409
|
Fixed issue 4, bad calculation of remaining length in big PublishDecoder.
|
2012-09-16 17:22:13 +02:00 |
|
|
andrea
|
522a0ecb4a
|
Fixed imports
|
2012-09-16 15:05:15 +02:00 |
|
|
selva.andre
|
74dfdc7702
|
Fixed typo
|
2012-09-12 00:28:25 +02:00 |
|
|
selva.andre
|
501c3fffe6
|
Merge branch 'split_in_other_modules'
|
2012-09-12 00:25:50 +02:00 |
|
|
selva.andre
|
34e5177da6
|
Extracted client module
|
2012-09-12 00:25:30 +02:00 |
|
|
selva.andre
|
fe022cb19c
|
Added broker/terget to gitignore
|
2012-09-12 00:14:34 +02:00 |
|
|
selva.andre
|
ea62a684d0
|
Completed the exporting into broker module
|
2012-09-12 00:13:24 +02:00 |
|
|
selva.andre
|
3410f0f0ce
|
First raw code move from parser to newly created broker module
|
2012-09-11 23:39:07 +02:00 |
|
|
selva.andre
|
48b0b95e58
|
Added idea IDE files to gitignore
|
2012-09-11 23:23:31 +02:00 |
|
|
selva.andre
|
633688f184
|
Implemented the QoS 2 sending part for the server plus a unit test
|
2012-09-11 23:20:32 +02:00 |
|
|
selva.andre
|
b7c2585742
|
Fixed encoders and decoders declaration for the broker
|
2012-09-11 23:19:44 +02:00 |
|
|
selva.andre
|
c4f186b3c8
|
Added rough implementation for QoS 2 publish
|
2012-09-10 23:30:40 +02:00 |
|
|
selva.andre
|
87a51cf4c2
|
Removed the CleanInFlight evente, because the clean is done once the Publish QoS 1 is just published
|
2012-09-10 21:56:00 +02:00 |
|
|
selva.andre
|
db161599e9
|
Fixed imports
|
2012-09-09 21:52:54 +02:00 |
|
|
selva.andre
|
de2937d4dd
|
Renamed methods in SubscriptionStore, connect-> activate disconnect ->deactivate
|
2012-09-05 21:35:20 +02:00 |
|
|
selva.andre
|
d9d58e498f
|
Extracted private inner classes from SubscriptionStore to self contained classes
|
2012-09-05 21:30:13 +02:00 |
|
|
selva.andre
|
562c99b9ed
|
Moved SubscriptionStore and its stuff in separate package
|
2012-09-05 21:26:53 +02:00 |
|
|
selva.andre
|
2f67532fdd
|
Extracted part of setUp for some tests
|
2012-09-05 20:57:41 +02:00 |
|
|
selva.andre
|
fd0c336600
|
Re-enabled ignored test, moved from ServerIntegrationTests
|
2012-09-05 20:50:56 +02:00 |
|
|
selva.andre
|
0e3e1bf80b
|
Moved inner class StoredMessage from SimpleMsessaging to HawtDBStorageService
|
2012-09-05 20:12:26 +02:00 |
|
|
selva.andre
|
ff5c60a608
|
Fixed a test
|
2012-09-05 20:01:10 +02:00 |
|
|
selva.andre
|
1dafa02f53
|
Fixed error in storage of QoS publish messages, before stored with current clientID and not matching subscription's clientID
|
2012-09-05 19:39:57 +02:00 |
|
|
selva.andre
|
d1d7c9d9df
|
Fixed log message
|
2012-09-05 19:37:51 +02:00 |
|
|
selva.andre
|
2cc30e6ce1
|
Minor change added log on method call
|
2012-09-05 19:34:14 +02:00 |
|
|
selva.andre
|
fc223d0b0b
|
Added connect method to re-activate client subscription on the tree
|
2012-09-05 19:32:42 +02:00 |
|
|
selva.andre
|
59c7a85355
|
Minor change, added toString
|
2012-09-05 19:30:23 +02:00 |
|
|
selva.andre
|
8fdec31c35
|
Added message type to string decoder helper method
|
2012-09-05 19:29:27 +02:00 |
|
|
selva.andre
|
481b8a5fff
|
Added toString util method
|
2012-09-05 16:15:13 +02:00 |
|
|
selva.andre
|
626f12e619
|
Added brute force MINA testing client and server
|
2012-09-05 13:56:50 +02:00 |
|
|
selva.andre
|
37916f7cbe
|
Merged the intergation test part that uses Fusesource MQTT client
|
2012-09-04 16:41:40 +02:00 |
|
|
selva.andre
|
f00e5494fb
|
Removed unused imports
|
2012-09-04 16:23:49 +02:00 |
|
|
selva.andre
|
8f3041fe56
|
Cleanedup MQTTHandler after the move of logic into the event loop
|
2012-09-04 16:23:11 +02:00 |
|
|
selva.andre
|
0e1a3cef6c
|
Moved subscription logic inside the event loop
|
2012-09-04 16:20:53 +02:00 |
|
|
selva.andre
|
70ad0c0475
|
Removed no more used Unsubscribe event
|
2012-09-04 15:46:24 +02:00 |
|
|
selva.andre
|
ddc835d1f3
|
Minor change, removed commented code added a comment
|
2012-09-04 15:44:29 +02:00 |
|
|
selva.andre
|
d6f6892d37
|
Moved Unsubscribe message handling inside event loop
|
2012-09-04 15:42:37 +02:00 |
|