 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 |
|
|
selva.andre
|
598efd26f3
|
Moved disconnect message handling inside event loop
|
2012-09-04 15:14:16 +02:00 |
|
|
selva.andre
|
342a6a6187
|
Moved publish message handling inside event loop
|
2012-09-04 14:57:56 +02:00 |
|
|
selva.andre
|
bfc4193b76
|
First step in moving protocol message processing inside the event handler
|
2012-09-04 14:30:17 +02:00 |
|
|
selva.andre
|
a52845a4c2
|
Parametrized the code for benchmark Producers
|
2012-09-04 13:58:33 +02:00 |
|
|
selva.andre
|
e56662fbef
|
Removed commented code
|
2012-09-04 10:25:08 +02:00 |
|
|
selva.andre
|
7d5e91afae
|
Merge branch 'change_from_blocking_queue_to_disruptor'
|
2012-09-04 10:15:52 +02:00 |
|
|
selva.andre
|
ab65cd250c
|
Minor change on server statistics
|
2012-09-04 10:15:17 +02:00 |
|
|
selva.andre
|
588374646e
|
Moved from List of persistent subscription to Set to avoid duplication
|
2012-09-03 22:08:47 +02:00 |
|
|
selva.andre
|
1337d8dd5f
|
Removed commented code
|
2012-09-03 22:02:39 +02:00 |
|
|
selva.andre
|
9d0aaa0eb5
|
Renamed close method and event to more clear Stop
|
2012-09-03 21:59:00 +02:00 |
|
|
selva.andre
|
870eb12390
|
* Moved the initialization of SimpleMessaging into the event loop, with an InitEvent
* Modified SimpleMessaging to be a reusable singleton, with init and close methods
|
2012-09-03 21:52:52 +02:00 |
|
|
selva.andre
|
a2c5c83a48
|
Silly change, fixed a typo on a comment
|
2012-09-03 18:17:44 +02:00 |
|
|
selva.andre
|
babad2942a
|
Simple change, added wait barrier in a test
|
2012-09-03 18:17:00 +02:00 |
|
|
selva.andre
|
bddd8e0745
|
Moved testing for Connect from MQTTHandler to SimpleMessaging
|
2012-09-03 12:14:31 +02:00 |
|
|
selva.andre
|
41f11a14e3
|
Missed from prev commit
|
2012-09-02 17:03:04 +02:00 |
|
|
selva.andre
|
cfa0e19205
|
Reoved blocking queue in favor of LMAX disruptor
|
2012-09-02 16:57:21 +02:00 |
|
|
selva.andre
|
c69802ef91
|
Merge branch 'move_sessions_management_into_protocol_logic'
|
2012-09-02 16:54:51 +02:00 |
|
|
selva.andre
|
217e754de2
|
Moved IoSessions management into the event loop
|
2012-09-02 11:31:18 +02:00 |
|
|
selva.andre
|
21d6d5880c
|
Minor change, reorganized imports
|
2012-09-01 17:05:58 +02:00 |
|
|
selva.andre
|
3c99be6d25
|
Merge branch 'storage_service_extraction'
|
2012-09-01 17:02:42 +02:00 |
|
|
selva.andre
|
8519b47dc2
|
Minor change, field renaming
|
2012-09-01 17:00:57 +02:00 |
|
|
selva.andre
|
a5d28b67e9
|
Moved all HawtDB stuff into HawtDBStorageService
|
2012-09-01 17:00:22 +02:00 |
|
|
selva.andre
|
ae8a2afb8b
|
Moved Subscriptions storage from SubscriptionStore to StorageService
|
2012-09-01 16:55:19 +02:00 |
|
|
selva.andre
|
6f88060ffe
|
Missed initialization in previous commit
|
2012-09-01 16:44:47 +02:00 |
|
|
selva.andre
|
b092d15c12
|
Moved the fling messages part persistence into StorageService
|
2012-09-01 16:28:03 +02:00 |
|
|
selva.andre
|
2ed87b2c1a
|
Moved the part to manage Pusblish messages persistence to StorageService
|
2012-09-01 16:18:09 +02:00 |
|
|
selva.andre
|
2f9c957310
|
Moved retained storage part into StorageService
|
2012-09-01 16:02:48 +02:00 |
|
|
selva.andre
|
2c2539e457
|
Removed refill method from IMessaging interface
|
2012-09-01 13:18:41 +02:00 |
|
|
selva.andre
|
25efc898a0
|
Finished to remove back notifier loop
|
2012-09-01 13:16:40 +02:00 |
|
|
selva.andre
|
9285691c62
|
Merge branch 'remove_the_back_notifier_loop'
|
2012-09-01 13:14:04 +02:00 |
|
|
selva.andre
|
9276ea8c98
|
Removed back notifier loop
|
2012-09-01 12:58:40 +02:00 |
|
|
selva.andre
|
42c04b074c
|
Merge branch 'implements_support_for_qos1'
|
2012-09-01 12:33:27 +02:00 |
|
|
selva.andre
|
e5fbf5c655
|
Added the storage of QoS1 messages for not clean sessions and the refire once the client reconnects
|
2012-09-01 12:33:06 +02:00 |
|
|
selva.andre
|
599afa76e6
|
Added the logic to de-activate subscriptions on client close
|
2012-09-01 11:44:07 +02:00 |
|
|
selva.andre
|
4ef628d0e6
|
Added active flag to Subscription
|
2012-09-01 11:41:57 +02:00 |
|
|
selva.andre
|
5644b8e048
|
Minor change corrected typos in comments
|
2012-09-01 11:17:24 +02:00 |
|
|
selva.andre
|
ba7f5284cf
|
Added cleanSession flag to Subscription class
|
2012-09-01 10:57:59 +02:00 |
|