selva.andre
585008e29d
Fixed API used by test calls
2012-08-31 17:14:40 +02:00
selva.andre
376140cab8
Fixed API used by test calls
2012-08-31 17:07:49 +02:00
selva.andre
90259d4148
First handling of QoS 1 level publish
2012-08-31 16:56:46 +02:00
selva.andre
6888d37fb6
Removed duplication of log lines
2012-08-30 11:37:38 +02:00
andrea
323811adb2
Added outbound event queue to be handled by Notifier stage
2012-08-29 21:20:36 +02:00
andrea
bb3e8170d5
Added log
2012-08-29 14:40:37 +02:00
andrea
f2220e664a
Removed commented code from client
2012-08-28 11:42:34 +02:00
andrea
a8773c3331
Fixed imports
2012-08-27 11:49:30 +02:00
andrea
d34201d0d9
Fixed tests
2012-08-27 11:48:54 +02:00
andrea
739f63bc40
Changed SimpleMessaging to be event driven (Incoming requests)
2012-08-27 11:48:21 +02:00
andrea
56431a161e
Minor change removed old commented code
2012-08-27 11:36:51 +02:00
andrea
f0064357f5
Minor change added a log
2012-08-27 11:36:26 +02:00
andrea
d2940741f8
Fixed a TU to wait an asych publish event
2012-08-27 11:35:42 +02:00
andrea
719b8f1894
Minor change, fixed imports
2012-08-26 13:40:14 +02:00
andrea
ce7bf469f3
Minor change, fixed imports
2012-08-26 13:38:42 +02:00
andrea
758301149a
Changed decodable message method to force loading the complete size of a message, before starting the real decode phase
2012-08-26 13:38:11 +02:00
andrea
1ee08d4847
Minor change added debug log
2012-08-26 13:16:01 +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
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