 andrea
|
bbe1acb143
|
Fixed issue #15 defined repositories into parent pom
|
2015-02-10 22:24:31 +01:00 |
|
|
andrea
|
4b836b441c
|
Marked oss snapshot repo as a snapshot repository
|
2015-02-10 22:03:12 +01:00 |
|
|
andrea
|
c30e053ab1
|
Removed moved files
|
2015-02-05 21:09:42 +01:00 |
|
|
andrea
|
fffa9afbfa
|
Divided integration and benchmark scripts
|
2015-02-05 21:08:18 +01:00 |
|
|
andrea
|
d731fddaf1
|
Added mqtt pub/sub synch(Paho lib) Future based and Callback/continuation based (Fuse lib)
|
2015-02-05 20:57:56 +01:00 |
|
|
andrea
|
9562f56a3a
|
Fixed issue #3, avoid hung up of broker on any message processing error
|
2015-01-31 12:19:50 +01:00 |
|
|
andrea
|
97dd07e1d4
|
Minor change, updated ChangeLog
|
2015-01-31 10:52:22 +01:00 |
|
|
andrea
|
155daa0335
|
Change null check to empty lists
|
2015-01-30 00:53:51 +01:00 |
|
|
andrea
|
aa79fe3145
|
Renamed session store management methods
|
2015-01-30 00:28:01 +01:00 |
|
|
andrea
|
b56d94d0bf
|
Fixed failing test
|
2015-01-30 00:27:44 +01:00 |
|
|
andrea
|
a3d505dd97
|
Switched MapDB to version 2.0.0-SNAPSHOT
|
2015-01-27 00:15:44 +01:00 |
|
|
andrea
|
72c8445693
|
Fixed issue #12, missed remove of already published retained messages
|
2015-01-27 00:15:14 +01:00 |
|
|
andrea
|
5fe9554965
|
Added test scripts to check issue4, but issue4 is not reproducible
|
2015-01-24 12:16:28 +01:00 |
|
|
andrea
|
95107e1624
|
Relaxed constraint on clientID length #11
|
2015-01-15 20:52:40 +01:00 |
|
|
andrea
|
1e63652d32
|
Fixed serious bug of client descriptor drop on connectionLost event for antoher client with sae ID (bug notified on email by ZhiPeng Yang)
|
2015-01-10 17:53:31 +01:00 |
|
|
andrea
|
6bde0e7c9b
|
Added script to simulate a bug (double client decription removal)
|
2014-12-28 18:08:43 +01:00 |
|
|
andrea
|
405f800908
|
Minor change, removed debug println
|
2014-12-28 17:27:49 +01:00 |
|
|
andrea
|
62edfd19f9
|
Fixed issue #5 and websocket implementation in general
|
2014-12-28 17:13:55 +01:00 |
|
|
andrea
|
176ebf9409
|
Minor change, lowered a log
|
2014-12-06 18:41:49 +01:00 |
|
|
andrea
|
275d63de18
|
Fixes #2, due to bad path of ConnectionIT during renaming from org.dna mqtt to org.eclipse.moquette
|
2014-12-06 18:38:53 +01:00 |
|
|
andrea
|
11c6c89c7d
|
Minor change, relayout xml
|
2014-12-06 18:01:19 +01:00 |
|
|
andrea
|
e6dba99aa8
|
Minor change, improved logging info
|
2014-12-06 17:56:54 +01:00 |
|
|
andrea
|
5b4a45a487
|
Updated to java 1.7
|
2014-12-02 22:21:28 +01:00 |
|
|
andrea
|
aac84677e4
|
Parameterized source and target platform
|
2014-12-02 22:18:24 +01:00 |
|
|
andrea
|
99148db07a
|
Upgraded Netty from 4.0.8 to 4.0.24
|
2014-12-02 22:07:55 +01:00 |
|
|
andrea
|
e4e5e7c681
|
Parameterized pom's netty version
|
2014-12-02 21:57:00 +01:00 |
|
|
andrea
|
263b59dae2
|
Added a script to check 2 clients with same ID fails
|
2014-11-30 18:28:37 +01:00 |
|
|
andrea
|
5dbd71b565
|
Added README.md
|
2014-10-05 15:33:47 +02: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
|
af79794300
|
Fixed conflict on .gitignore
|
2014-09-30 22:22:28 +02:00 |
|
|
Andrea Selva
|
acc1167fe1
|
Initial commit
|
2014-09-30 22:14:41 +02:00 |
|
|
selva.andre
|
fa5b953010
|
Minor changes on log defs
|
2014-09-30 21:13:43 +02:00 |
|
|
selva.andre
|
10081b3880
|
Minor change, wiped subscription also from persistent store
|
2014-09-19 22:49:23 +02:00 |
|
|
selva.andre
|
d944a0e7c6
|
Minor change, renamed splitTopic to parseTopic
|
2014-09-19 22:30:35 +02:00 |
|
|
selva.andre
|
0940ac84a0
|
Fixed bug due to not persisted subscriptions into the store, on restart there were ghosts subscriptions that produced errors
|
2014-09-19 22:00:51 +02:00 |
|
|
selva.andre
|
cc45b87ebe
|
Added some benchmariking utils: benchmarker produces tiing csv and an html using Highcharts JS lib
|
2014-09-19 21:51:24 +02:00 |
|
|
selva.andre
|
1a66bc4645
|
Minor change, added log line end fixed typo in methond name
|
2014-09-19 14:25:40 +02:00 |
|
|
selva.andre
|
359556909c
|
Minor change
|
2014-09-19 13:31:25 +02:00 |
|
|
selva.andre
|
2e4e060b46
|
Upgraded from disruptor 2.7.3 to 3.3.0
|
2014-09-18 22:18:19 +02:00 |
|
|
selva.andre
|
c624c040b7
|
Fixed conflict
|
2014-09-09 17:39:35 +02:00 |
|
|
selva.andre
|
bae1987704
|
Minor chaneg
|
2014-09-09 17:37:18 +02:00 |
|
|
selva.andre
|
04f6150399
|
Applied patch 0001-Moved-spec-tests-to-different-package.-Added-spec-te.patch from Prashant for Will behaviour
|
2014-09-09 17:35:35 +02:00 |
|
|
selva.andre
|
fe66116dde
|
Added basic connect-close TCK from Prashant Khanal
|
2014-09-09 17:35:35 +02:00 |
|
|
selva.andre
|
24282fe0ab
|
Minor, removed MapDB shutdown hook because it's responsibility of the Moquette shutdown hook to teardown the storage
|
2014-09-09 17:06:13 +02:00 |
|
|
selva.andre
|
26ff8070ac
|
Removed db.close because already handled by MapDB shutdown handler
|
2014-09-09 16:04:04 +02:00 |
|
|
selva.andre
|
7040567aab
|
Removed unused dependency to HawtDB after switch to MapDB
|
2014-09-09 11:42:39 +02:00 |
|
|
selva.andre
|
d581db23f8
|
Fixed error in NoClassFoundError due to bad import into MapDB, switched to 1.1.0 (include DynamicImport OSGi
|
2014-09-08 15:47:07 +02:00 |
|
|
selva.andre
|
b792e3695d
|
Applied patch 0001-Moved-spec-tests-to-different-package.-Added-spec-te.patch from Prashant for Will behaviour
|
2014-09-07 10:32:12 +02:00 |
|
|
selva.andre
|
27c5d75871
|
Added basic connect-close TCK from Prashant Khanal
|
2014-09-02 23:11:05 +02:00 |
|
|
selva.andre
|
f3e6b71e09
|
Dropped HawtDB persistence
|
2014-09-01 22:06:27 +02:00 |
|
|
selva.andre
|
c83baae50d
|
Switched from HawtDB to MapDP store
|
2014-08-30 15:59:59 +02:00 |
|
|
selva.andre
|
7314dbee73
|
Extracted common Netty bootstrapping method
|
2014-08-26 21:55:42 +02:00 |
|
|
selva.andre
|
2be0fd84fe
|
Fixed bug once the moquette.conf provided doesn't provide a valid path to pasword.conf
|
2014-08-23 12:34:31 +02:00 |
|
|
selva.andre
|
0593b19d51
|
Minor chaneg
|
2014-08-23 12:29:06 +02:00 |
|
|
selva.andre
|
c0ebbb0b44
|
Removed redundant if in protocol dispatching
|
2014-08-18 23:32:07 +02:00 |
|
|
selva.andre
|
81a084984b
|
Minor change, changed layout of dispather if-else
|
2014-08-18 23:29:43 +02:00 |
|
|
selva.andre
|
5c5e640b04
|
Removed some unusefull PublishEvent constructros
|
2014-08-18 23:27:08 +02:00 |
|
|
selva.andre
|
aee85a7cb0
|
Added also PublishMessage to be dispatched by annotation based dispather
|
2014-08-18 23:02:56 +02:00 |
|
|
selva.andre
|
98f04859ab
|
Canged behaviour of AnnotationSupport to throw an exception on message not matched
|
2014-08-18 22:57:53 +02:00 |
|
|
selva.andre
|
4fe7b6754c
|
Minor change, renamed test class (fixed typo)
|
2014-08-18 22:51:04 +02:00 |
|
|
selva.andre
|
43d19e02a6
|
Renamed AnnotationHelper to AnnotationSupport
|
2014-08-17 22:03:25 +02:00 |
|
|
selva.andre
|
2c90b1386d
|
Removed an used DisconnectEvent
|
2014-08-17 17:11:26 +02:00 |
|
|
selva.andre
|
b737cde803
|
Removed unused InitEvent
|
2014-08-17 17:09:18 +02:00 |
|
|
selva.andre
|
9f3d7baf05
|
Removed unused InitEvent
|
2014-08-17 17:01:08 +02:00 |
|
|
selva.andre
|
0e729b51bf
|
Used annotation dispatch for some protocol messages
|
2014-08-17 16:58:51 +02:00 |
|
|
selva.andre
|
5446d25528
|
Used annotation dispatch for some protocol messages
|
2014-08-17 16:47:14 +02:00 |
|
|
selva.andre
|
43677cca89
|
Introduced annotation based dispacth to invoke ProtocolProcessor methods
|
2014-08-17 16:14:35 +02:00 |
|
|
selva.andre
|
dbe270539b
|
Minor change, cleaned imports
|
2014-08-17 16:11:28 +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
|
b0ef8114b6
|
Minor change, simulated a client connect to avoid staktrace in log
|
2014-08-02 10:56:34 +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
|
d4e13e8543
|
Minor change, added groovy script to check embeddability of the broker
|
2014-07-13 12:26:58 +02:00 |
|
|
selva.andre
|
c79f2d0a96
|
Started 0.7 development cycle
|
2014-07-12 18:22:54 +02:00 |
|
|
selva.andre
|
aa24b19d2b
|
Bumped release 0.6
|
2014-07-12 16:30:13 +02:00 |
|
|
selva.andre
|
883ac4590c
|
Minor change
|
2014-07-12 13:43:33 +02:00 |
|
|
selva.andre
|
6e360bef93
|
Moved slf4j-log4j deps out of broker (and also log4j.properties) to let the broker easyli embedded using container provided logging confgiuration
|
2014-07-12 13:41:47 +02:00 |
|
|
selva.andre
|
5df734fcf7
|
Added various start methods to pass the configuration at startup
|
2014-07-12 12:56:38 +02:00 |
|
|
selva.andre
|
bfb2b56599
|
Minor change
|
2014-06-30 23:37:28 +02:00 |
|
|
selva.andre
|
08e12494ec
|
Separated the interfaces to persist messages from the one that persists sessions
|
2014-06-30 23:36:00 +02:00 |
|
|
selva.andre
|
d8ec0f2e94
|
Minor change, just renamed method
|
2014-06-30 23:00:39 +02:00 |
|
|
selva.andre
|
665e60a646
|
Extracted the persistence dependency from SubscriptionsStore
|
2014-06-30 22:59:37 +02:00 |
|
|
selva.andre
|
90cfe1ac23
|
Extracted the persistence dependency from SubscriptionsStore
|
2014-06-30 22:46:11 +02:00 |
|
|
selva.andre
|
1afa7601c9
|
Minor change, renamed topic to topicFilter in Subscription
|
2014-06-30 22:21:52 +02:00 |
|
|
selva.andre
|
d22ec1cf7a
|
Minor change, remove unused (and without any meaning) session parameter from PublishEvent
|
2014-06-15 18:47:17 +02:00 |
|
|
selva.andre
|
fdc7f6237e
|
Added memory store for will messages and implemented the correct publishing
|
2014-06-15 18:16:24 +02:00 |
|
|
selva.andre
|
17d2ab505c
|
Minor change updated the FuseSource's mqtt client lib
|
2014-06-15 18:06:00 +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 |
|
|
selva.andre
|
0bbe719f16
|
Updated the pax-runner to fix issue #40
|
2014-06-11 23:00:05 +02:00 |
|
|
selva.andre
|
c23147185e
|
Minor added netty http codec also to OSGi bundle
|
2014-06-08 12:24:31 +02:00 |
|