Commit Graph
54 Commits
Author SHA1 Message Date
Victor Kazakov fc1ac5973f Adding unit test to check that PubRelEncoder encodes PubRel message flag to match what is in the MQTT specification (both 3.1.1 and 3.1). See Appendix B: MQTT-3.6.1-1 2015-08-25 09:26:51 -07:00
Victor Kazakov d8e432b4cf Fixing PubRelEncoder to encode PubRel message flag to match what is in the MQTT specification http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Toc398718054 2015-08-24 15:10:56 -07:00
andrea bafcca4c58 Added checking of valid topicFilter format in unsubscribe 2015-08-10 23:07:47 +02:00
andrea c3224c2a5b Minor change, updated copyright to 2012-2015 2015-08-08 19:36:14 +02:00
andrea 0c114d3dab Minor changed, fixed typo in method name (ProcotolVersion to ProtocolVersion) 2015-08-08 19:03:27 +02:00
andrea 5bfc73fafb Minor changes 2015-08-01 16:45:28 +02:00
andrea 8b48a82968 Fix bug in bad validation of topic names and topic filters, they should be at least 1 char wide (issue #67) 2015-08-01 16:13:24 +02:00
andrea fd1df47fec Fixed issue #65 2015-08-01 11:59:00 +02:00
andrea 867d78b650 Fixed issue #43, not clean handlng of bad formatted topic filters during subscrion 2015-06-20 18:27:43 +02:00
andrea 0602325974 Added simple handler to test the codec speed 2015-06-02 16:48:27 +02:00
andrea 1eb47dec6a Minor fix for Paho perf groovy scripts 2015-06-02 16:37:01 +02:00
andrea 647773cd2e Fixed netty buff memory leak bug #27 2015-04-07 00:22:01 +02:00
andrea 4baf407657 Integrated by hand part of the pull request #13 'fix pom and clean deprecated class and add bat file to windows' 2015-03-04 22:40:56 +01:00
andrea 528c263930 Moved integration raw test from Kaazing robot to an internal Java DSL 2015-03-04 00:26:09 +01:00
andrea 7bcd437664 Changed package from org.dna.mqtt to orga.eclipse.moquette 2014-10-05 13:22:30 +02:00
andrea a599c38537 Moved parser_commons submodule to org.eclipse.moquette 2014-10-05 10:53:45 +02:00
selva.andre e724a1ee9e Minor change, redefined signature of DemuxDecoder.decode to use the more gneric AttributeMap instead of ChannelHandlerContext 2014-08-03 11:24:14 +02:00
selva.andre 161421a00c Renamed subscribe and unsubscribe topic to topicFilter 2014-08-03 11:17:25 +02:00
selva.andre e40e19cd1e Spreaded the validation of fixed flags 2014-08-03 11:09:21 +02:00
selva.andre b7fc92e343 Changed DemuxDecoder.decodeCommonHeader to also validate the fixed part flags (if needed) 2014-08-03 11:01:09 +02:00
selva.andre f343ce3094 Adapted Unsuscribe decoder to be 3.1.1 compliant 2014-08-02 12:34:03 +02:00
selva.andre d1b54eb8cf Updated SUBSCRIBE to be 3.1.1 compliant 2014-08-02 12:30:28 +02:00
selva.andre 53f87a6e4f Added check of reserved flags for PUBREL message 2014-08-02 11:37:31 +02:00
selva.andre d4ef81a7ef Updated publish message parto to conform to 3.1.1 specification 2014-07-31 00:08:41 +02:00
selva.andre 482ffe0c65 Introduced handling of sessionPresent flag in ConnAck msg, now on every conenction is created an empty subscription in ISessionStore 2014-07-27 12:20:53 +02:00
selva.andre bd3c4cb40c Added clinetID=empty then reject connect rule 2014-07-26 18:22:32 +02:00
selva.andre 8185811188 Added check for MQTT 3.1.1 reserved flag == 0 on connect flags 2014-07-23 00:08:59 +02:00
selva.andre 465d7123f6 Introduced version, reserved flags untouchable and double connect 3.1.1 proto version 2014-07-21 23:14:26 +02:00
selva.andre 666cc29d47 Added copyright and license notice to every source file, added about.html and license.htl 2014-06-11 23:40:19 +02:00
andrea b0d9bc2d6a Simplified buffer allocation for SubAck encoding part 2014-02-23 12:58:11 +01:00
andrea 16ccfeda1d Added release operation on all ByteBuf used in encoding part 2014-02-23 12:46:37 +01:00
andrea bd3a1f6c4d Changed the use of string concatenation of String.format in favor of formatted logging methods 2013-11-27 10:43:08 +01:00
andrea e9bb34898b Adapted Netty parser to use ByteBuffer instead of byte[] 2013-11-26 12:25:48 +01: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 466e0946d6 Given public visibility to MQTT Endoer/Decoer constructors to be used from the broker 2013-09-14 15:06:19 +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 2c9858c261 Added encode/decode for SubAck message 2013-09-12 15:58:53 +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 28b37f68ea Added encode/decode for Publish message 2013-09-12 12:38:31 +02:00
andrea 1baa16b8e3 Extracted a TestUtils method mockChannelHandler 2013-09-11 17:51:59 +02:00
andrea 93859d1a63 Added encode/decode for ConnAck message 2013-09-11 17:48:07 +02:00
andrea 22fe25da32 Introduced hierarchy for message encoders 2013-09-11 16:47:41 +02:00