 selva.andre
|
9603310b4e
|
Minor change, updated ChangeLog
|
2013-11-25 09:33:40 +01:00 |
|
|
andrea
|
056ab10121
|
Re-enabled commented tests
|
2013-11-24 14:44:23 +01:00 |
|
|
andrea
|
9cec0af484
|
Removed the Mina parser
|
2013-11-24 11:52:10 +01:00 |
|
|
andrea
|
1fa810362f
|
Removed dependency on Mina IO framework
|
2013-11-24 11:51:15 +01:00 |
|
|
andrea
|
817ca8e176
|
Added output reactor to isolate the writing of messages
|
2013-11-14 16:43:03 +01:00 |
|
|
selva.andre
|
7a7c5cc53e
|
Added script to test issue 9, publish of a QoS2 message
|
2013-11-07 11:55:23 +01:00 |
|
|
andrea
|
49d1b2c948
|
Added tests suite used by Roger Light to check SubscriptionStore.matchTopics
|
2013-11-06 13:37:23 +01:00 |
|
|
andrea
|
2c18ee92c7
|
Added tests suite used by Roger Light to check SubscriptionStore.matches
|
2013-11-06 12:35:10 +01:00 |
|
|
andrea
|
136b7e25c3
|
Set up for next development cycle (version 0.4)
|
2013-11-06 10:44:29 +01:00 |
|
|
selva.andre
|
af8c0e3b9a
|
Added Apache 2.0 license
|
2013-10-04 14:03:38 +02:00 |
|
|
selva.andre
|
f4162c2868
|
Bumped 0.3
|
2013-09-23 12:26:37 +02:00 |
|
|
selva.andre
|
64e332f3d5
|
Added file appender and defined threshold for various appenders
|
2013-09-23 12:16:00 +02:00 |
|
|
selva.andre
|
7bcaadf6ee
|
Added scripted use cases
Minor changes to logging
|
2013-09-23 11:46:48 +02:00 |
|
|
selva.andre
|
56faccd2fc
|
Added the creation of broker assembly to the package phase
|
2013-09-20 20:00:02 +02:00 |
|
|
selva.andre
|
04478e77e1
|
Added Message and Bytes read/write metrics
|
2013-09-20 19:25:19 +02:00 |
|
|
selva.andre
|
1e83f3c035
|
Parametrized version number and bumped 0.3-SNAPSHOT
|
2013-09-20 11:19:17 +02:00 |
|
|
selva.andre
|
4e27ee638a
|
Removed Fusesource mqtt client based test because the lib seems not working correctly (random cyclic reconnects)
|
2013-09-20 11:12:06 +02:00 |
|
|
selva.andre
|
a6164f7464
|
Removed netty_parser/target from git commits
|
2013-09-19 20:15:50 +02:00 |
|
|
selva.andre
|
81b6516cac
|
* Reimplemented the Fuse integration tests into Paho client lib
* Extracted common pom properties
|
2013-09-19 20:14:07 +02:00 |
|
|
selva.andre
|
f09fcd6cd5
|
Minor fixes to typos
|
2013-09-19 20:11:52 +02:00 |
|
|
selva.andre
|
1dfc6ff77c
|
Switched the default connector from MINA to Netty
|
2013-09-19 20:10:18 +02:00 |
|
|
selva.andre
|
ecfe3e0936
|
Added default idle connection timeout in a ChannelPipeline
|
2013-09-19 20:09:46 +02:00 |
|
|
selva.andre
|
576704562e
|
Minor code relayout
|
2013-09-19 12:22:06 +02:00 |
|
|
selva.andre
|
8f10f3ed15
|
Moved the clientIDs map (ConnectionDescriptors cache) from SimpleMessaging to ProtocolProcessor
|
2013-09-17 11:08:05 +02:00 |
|
|
selva.andre
|
3d3432762e
|
Merge branch 'porting_mina_2_netty'
|
2013-09-15 17:19:04 +02:00 |
|
|
andrea
|
ac5fb3c9ac
|
Added Netty connection stuff for the I/O
|
2013-09-15 17:18:26 +02:00 |
|
|
andrea
|
63842088a4
|
Minor change, implemented trivial toString()
|
2013-09-15 16:17:03 +02:00 |
|
|
andrea
|
3ce369ab43
|
Fixed bug in the calculation of payload site in publish decoder due to bad startPos recording
|
2013-09-15 15:31:09 +02:00 |
|
|
andrea
|
6269330364
|
Minor change, reorganized imports
|
2013-09-14 15:06:44 +02:00 |
|
|
andrea
|
466e0946d6
|
Given public visibility to MQTT Endoer/Decoer constructors to be used from the broker
|
2013-09-14 15:06:19 +02:00 |
|
|
andrea
|
51f0ba7e1c
|
Added message type to every message
|
2013-09-14 12:57:06 +02:00 |
|
|
andrea
|
30e165c8ce
|
Separated all mina related stuff in classes to avoid main protocol loop to depend on mina related stuff
|
2013-09-13 12:44:53 +02:00 |
|
|
andrea
|
70befbcd77
|
Fixed version of parent pom
|
2013-09-13 11:50:11 +02:00 |
|
|
andrea
|
5382a9c467
|
Removed old unused client lib
|
2013-09-13 11:33:53 +02:00 |
|
|
andrea
|
8ade5f68aa
|
Extracted front MINA connector
|
2013-09-13 10:24:04 +02:00 |
|
|
andrea
|
6fb4682d8b
|
Added encode/decode for PubRel message
|
2013-09-12 17:14:21 +02:00 |
|
|
andrea
|
47bdb27261
|
Added encode/decode for PubRec message
|
2013-09-12 17:12:02 +02:00 |
|
|
andrea
|
dcffda5c4f
|
Added encode/decode for PubComp message
|
2013-09-12 17:08:20 +02:00 |
|
|
andrea
|
fa8a12a6f2
|
Added encode/decode for UnsubAck message
|
2013-09-12 17:00:21 +02:00 |
|
|
andrea
|
3066cfdd04
|
Added encode/decode for PingResp message
|
2013-09-12 16:53:33 +02:00 |
|
|
andrea
|
3fa3705d55
|
Added encode/decode for PingReq message
|
2013-09-12 16:50:36 +02:00 |
|
|
andrea
|
ef8f794b93
|
Added encode/decode for Disconnect message
|
2013-09-12 16:44:06 +02:00 |
|
|
andrea
|
52402536d9
|
Added encode/decode for Unsubscribe message
|
2013-09-12 16:28:51 +02:00 |
|
|
andrea
|
daa637c557
|
Minor cleaned imports
|
2013-09-12 16:14:51 +02:00 |
|
|
andrea
|
58017f45a1
|
Minor cleaned imports
|
2013-09-12 16:01:40 +02:00 |
|
|
andrea
|
2c9858c261
|
Added encode/decode for SubAck message
|
2013-09-12 15:58:53 +02:00 |
|
|
andrea
|
9f2497e0f9
|
Minor cleaned imports
|
2013-09-12 15:17:42 +02:00 |
|
|
andrea
|
c3f5a69d68
|
Added encode/decode for Subscribe message
|
2013-09-12 15:16:55 +02:00 |
|
|
andrea
|
1b1cc715be
|
Added encode/decode for PubAck message
|
2013-09-12 14:45:04 +02:00 |
|
|
andrea
|
facec04ac2
|
Minor cleaned imports
|
2013-09-12 14:30:25 +02:00 |
|