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
andsel
5a5f723d5f
Fixed a name clashing
2012-08-03 16:32:21 +02:00
andsel
c70163f7ef
Fixed imports
2012-08-03 16:30:50 +02:00
andsel
147ef71e06
Fixed buggy test
2012-08-03 16:30:27 +02:00
andsel
8ded145b96
Missed in prev commit
2012-08-03 16:22:25 +02:00
andsel
e6756b3c06
Extracted a store for subscriptions
2012-08-03 16:16:41 +02:00
andsel
f18ba2e248
Fixed potential indefinite lock retention
2012-08-03 15:44:11 +02:00
selva.andre
41f03b2d3e
Switched from plain synchronized to ReadWrite locking
2012-08-01 23:51:25 +02:00
selva.andre
f0dd3f1f2e
Added shutdown hook to the server to unbind correctly the port
2012-08-01 23:37:55 +02:00
selva.andre
3ad7366077
Introduced MQTT logging filter to display more clear message's headers
2012-08-01 23:23:03 +02:00
selva.andre
683ac4e6f6
Switched to slf4j backing on log4j configuration
2012-07-31 22:49:35 +02:00
andrea