anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
1,183 Commits 2 Branches 127 Tags
c839c9eadd8540a025174800cc374bacd0d1bcae
Commit Graph
100 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
andsel c839c9eadd Minor 2018-04-27 12:46:23 +02:00
andsel 5456431dd4 Fixed bug #400 a transient session (clean=true) that tried to lookup session from persistent store 2018-04-27 12:44:48 +02:00
andsel 08949370e6 Minor added slf4j-api deps to re-enable logging 2018-04-27 12:43:11 +02:00
andsel 033a428184 Fixed checkStyle and ErrorProne warns 2018-04-26 22:23:06 +02:00
Andrea Selva 1a6dd8a259 Update about.html 
Update the about after request from Eclipse Foundation
 2018-04-16 18:12:48 +02:00
Andrea Selva 4307a90333 Merge pull request #392 from AndreasMager/gradle_update 
Build tools update.
 2018-03-12 19:40:30 +01:00
Andrea Selva 2fb475ae95 Merge pull request #389 from MBOIX/fix/issue_375 
Fixed issues #375, #312
 2018-02-11 18:39:57 +01:00
Andrea Selva 5d02ecdf94 Merge pull request #370 from ningg/master 
feature: update Readme file.
 2017-10-31 14:54:03 +01:00
Andrea Selva 95a8b313e5 Merge pull request #365 from mwilliford/master 
Fix for CTrie TNode exception and other improvements to CTrie related
 2017-10-25 09:05:41 +02:00
andsel 3293478dd7 Fixed issue #362 2017-10-20 12:27:50 +02:00
andsel ba2b8b44d3 Fixed issue #360, used a DB connection pool instead of long lasting Drivers connections 2017-10-20 12:25:10 +02:00
andsel f7b213a677 Added tracking of closed session time and expired session cleaner for clients that never reconnects but had clean session flag = false 2017-10-20 11:48:34 +02:00
Andrea Selva a49792adf5 Added GitHub Issue template 2017-10-20 11:45:43 +02:00
andsel 1b272e5849 Big refactory on session management: 
- introduced a unique point of access and management of sessions state (SessionRepository)
- separated behaiour for sessions with clean flag to false into DurableSession
- separated behaviour for session with clean flag to true into TransientSession
 2017-10-14 17:37:26 +02:00
andsel 6bacce6cec Removed project moquette-embedded-test from settings 2017-08-26 16:47:24 +02:00
andsel 6f533d23c6 Removed OSGi support, too buggy 2017-08-26 16:30:37 +02:00
Andrea Selva c367100e6b Merge pull request #345 from AndreasMager/gradle 
Switched build from Maven to Gradle
 2017-08-24 19:20:38 +02:00
Andrea Selva 7c4f902dbd Merge pull request #350 from AndreasMager/test_setup_improvement 
Test setup improvement
 2017-08-24 11:11:01 +02:00
Andrea Selva dbd1310eb3 Merge pull request #349 from AndreasMager/h2-fixes 
Bugfix: H2 Storage
 2017-08-23 21:21:55 +02:00
Andrea Selva ed87abaaaa Merge pull request #340 from nMoncho/ACL_COMMENTS 
#310 - Allow for topic/patterns with '#' and end of line comments
 2017-08-23 10:02:29 +02:00
Andrea Selva d6aca1d2a1 Merge pull request #342 from hylkevds/master 
Terminate processor on shutdown.
 2017-08-19 14:36:46 +02:00
Andrea Selva 898ebab6d8 Merge pull request #343 from Dolychuck/issue#171 
Fix issue #171
 2017-08-19 14:33:03 +02:00
andsel d7023ae81b Extracted common subscriptions directory interface and switched to CTrie inspired implementation 2017-07-29 17:10:01 +02:00
Andrea Selva c81fab62e6 Merge pull request #334 from AndreasMager/fix-clean-session-logging 
MemorySessionStore#cleanSession: fixed logging
 2017-07-11 10:03:09 +02:00
Andrea Selva 14091f142d Merge pull request #332 from AndreasMager/fix_bat_file 
distributon/moquette.bat: comments fixed
 2017-07-11 09:35:32 +02:00
andsel 23b903e2f2 - moved and cleaned many part of Paho integration tests to unit tests 
- fixed bug that on conflicting connect close old channel but not dropped from ConnectionDescriptors cache
 2017-06-29 17:00:14 +02:00
andsel 03c4874a50 Moved tests from integration to unit and extracted and simplified common test part in ProtocolProcessor unit test 2017-06-29 16:59:56 +02:00
andsel 83be327bd3 Started dev cycle for 0.11 2017-06-29 16:59:56 +02:00
Andrea Selva 4e14655f45 Merge pull request #302 from AndreasMager/add-ByteBuf.release 
Add ByteBuf.release
 2017-06-27 16:50:05 +02:00
andsel 458840a0d7 Minor, fixed BinTray packages 2017-06-27 12:03:54 +02:00
andsel 0480260a56 Bumped release 0.10 2017-06-27 11:33:49 +02:00
andsel ae9c6c7a48 Minor, marked bugsnag ChannelHandler to @Sharable 2017-06-25 12:33:10 +02:00
andsel 3ff3d44d35 Added bugsnag catcher to the pipeline 2017-06-25 11:11:56 +02:00
andsel c243d518a9 Minor, added real demo broker reference 2017-06-21 22:47:05 +02:00
andsel ec951738b5 Added BugSnag error tracker 2017-06-20 22:12:42 +02:00
andsel 04a82c4a63 Added num of connected clients and subscription request/sec 2017-06-20 21:55:59 +02:00
andsel 53ec8e5b60 Removed the constraint on client queues to be BlockingQueue but simple Queue 2017-06-20 21:55:59 +02:00
Andrea Selva 1f3d39f4b1 Merge pull request #264 from AndreasMager/java-1.8 
Java 1.8
 2017-06-19 17:19:53 +02:00
andsel 555893d287 Switched to Java 8 2017-06-18 11:41:37 +02:00
andsel e0104d99f9 Introduced DropwizardMetrics to push data on Librato 2017-06-18 11:04:24 +02:00
andsel 16a9a0ccd0 Fixed runtime loading of persistence implementation 2017-06-18 11:01:25 +02:00
andsel e848ecf9bc Included MapDB and H2 persistence in distribution 2017-06-18 10:59:26 +02:00
andsel 949e531448 Switched to Netty 4.1.12 to use MqttMessageBuilders 2017-06-10 16:55:00 +02:00
Andrea Selva f4afd451ab Merge pull request #314 from hylkevds/master 
Terminate interceptor on shutdown.
 2017-06-10 16:00:12 +02:00
Andrea Selva d5a8e3f7b4 Merge pull request #321 from AndreasMager/add-session-class-for-memory-session-store 
MemorySessionStore: Session class added
 2017-06-05 08:57:14 +02:00
andsel 46a215bd2c Minor, fixed bad import 2017-06-02 10:21:26 +02:00
andsel d9ff81131c Merged topic subscription search and publish into single MessagePublisher method 
First step on implementing H2 storage

Minor, fixed not imported class

Cleaned MessageStore interface to avoid duplication of methods used in couple. Switched from guid + message to move messages

Separated ISubscriptionsStore from ISessionStore

Implemented H2 queue
 2017-06-02 10:13:34 +02:00
Andrea Selva c18c915dd2 Merge pull request #315 from AndreasMager/netty-epoll 
Netty epoll system added, thanks
 @AndreasMager
 2017-05-25 23:42:12 +02:00
andsel 2f25863578 Fixed failig message logger 2017-04-30 11:53:15 +02:00
andsel 85a787993c Added missing persist on QoS1 retained publish 2017-04-30 11:31:05 +02:00
andsel 406ffd10db Merged topic subscription search and publish into single MessagePublisher method 2017-04-29 10:59:34 +02:00
Andrea Selva 67ab24570e Merge pull request #301 from AndreasMager/missing-message-logging-added 
Missing message logging added
 2017-04-25 17:39:38 +02:00
Andrea Selva 3a0eb3bea1 Merge pull request #297 from AndreasMager/gc1 
Gc1 garbage collector added to start scripts
 2017-04-20 14:14:40 +02:00
Andrea Selva c1694ec6e2 Merge pull request #296 from AndreasMager/checkstyle-improvements 
checkstyle: NewlineAtEndOfFile fixed for windows
 2017-04-14 14:08:15 +02:00
Andrea Selva 9d23bf934e Merge pull request #295 from AndreasMager/warnings-removed 
Checkstyle warnings removed
 2017-04-14 09:04:19 +02:00
andsel 6dc762f47f Introduced the FlightZone concept (inbound and outbound) and separated logic of storage system. 2017-04-09 19:22:50 +02:00
andsel 5c6889fbd5 Separated persistence layer, created submodule for MapDB persistence letting the broker use the in-memory message store 2017-04-01 16:21:34 +02:00
andsel 7ffb8fb43b Minor, just layout 2017-03-25 15:40:33 +01:00
andsel 9440352e56 Minor, fixes the output of mapdb data into targetdir (solves #288) 2017-03-25 15:38:10 +01:00
Andrea Selva f8282eff7e Merge pull request #278 from AndreasMager/move-executor 
ScheduledExecutorService moved from MapDBPersistentStore to Server
 2017-03-22 23:26:06 +01:00
Andrea Selva 6ca8108f1e Merge pull request #286 from fbeister/master 
Prevent usage of MsgId 0 when wrapping around
 2017-03-22 22:30:00 +01:00
Andrea Selva 451b5db941 Merge pull request #280 from fjcyue/master 
using reader idle to trigger the will message.
 2017-03-22 22:20:22 +01:00
andsel c659a54158 Minor, just code layout 2017-03-20 21:58:18 +01:00
Andrea Selva 22b1fa2b0e Merge pull request #269 from AndreasMager/istore 
Storage replacement with Config file
 2017-03-20 13:52:39 +01:00
andsel ec6ec09cee Minor fixed comment (#281) 2017-03-19 22:01:23 +01:00
andsel 46d27e3bea Removed Moquette parser module 2017-03-05 12:37:32 +01:00
andsel e5c46e7a55 Purge nodes without subscriptions as described by PR #274 2017-03-05 12:37:18 +01:00
Andrea Selva b0095aa3fd Merge pull request #270 from AndreasMager/add-topic-class 
New class added: Topic
 2017-02-19 19:35:54 +01:00
Andrea Selva 44fecb3b5a Merge pull request #271 from calvernaz/master 
Rename variable name
 2017-02-16 15:57:45 +01:00
Andrea Selva 8688a9d098 Merge pull request #265 from AndreasMager/fromating-broker 
Minor Checkstyle adjustement & Fromating broker folder
 2017-02-09 13:34:45 +01:00
Andrea Selva 682e905c49 Merge pull request #263 from AndreasMager/fix-subscriptions-preformance-test 
PerformanceTest: netty layout changes fixed
 2017-02-01 13:44:26 +01:00
Andrea Selva ff4c5dff3b Merge pull request #261 from AndreasMager/adding-assertj 2017-02-01 13:39:32 +01:00
Andrea Selva acc00863a4 Merge pull request #259 from AndreasMager/protocol-processor-test-fixed 
Protocol processor test fixed
 2017-02-01 13:36:17 +01:00
Andrea Selva 94d5afbff7 Merge pull request #262 from AndreasMager/checkstyle 
First Checkstyle version added
 2017-02-01 13:35:52 +01:00
andsel 1c64186a00 Switched from Moquette's MQTT codec to Netty's MQTT codec ones 2017-01-28 15:59:44 +01:00
Andrea Selva 07093ab0cb Merge pull request #255 from AndreasMager/subscription-store-performance-test 
Great thanks a lot
 2017-01-28 15:46:38 +01:00
Andrea Selva e3c4360b62 Merge pull request #256 from AndreasMager/memory-session-store-boost 
MemorySessionStore#m_persistentSubscriptions: Map Layout changed
 2017-01-26 21:43:16 +01:00
andsel 716c9ac0a0 Minor on logging, removed ugly if(isDebugEnabled()) for debug logging, kept only when the toString generation could potentially take long, and trasformed in tracing logs. Moved Error to Warn log level 2017-01-18 23:28:11 +01:00
andsel e295fcf9f2 Updated the list of contributors (not hexaustive) 2017-01-18 23:25:53 +01:00
andsel 60c28f1ecb Minor, just setted autogenerated random serialVersionUID instead of bad 1L 2017-01-18 22:46:04 +01:00
andsel 9b164019ec Fixed bad merge lines 2017-01-18 22:35:23 +01:00
andsel e777c54414 Merge branch 'Sofia2-master' with lots of improvements in dispatching events to interceptors 2017-01-18 22:26:35 +01:00
andsel 97ddd1cd8b Merge branch Sofia2 with lot of improvements 2017-01-17 21:40:59 +01:00
andsel a7b8c07d1a Bumped dev cycle for 0.10 2017-01-11 22:21:03 +01:00
andsel 4162aae3a0 Bumped version 0.9 2017-01-11 22:06:24 +01:00
andsel ac8a11fefa Removed the reference counter for stored messages 2017-01-09 21:59:09 +01:00
andsel 081631242f Removed old 'map based queues' to use persistent BlockingQueues from MapDB 2017-01-09 21:53:26 +01:00
andsel 3f0ab75efb Updated copiright to year 2017 2017-01-04 14:37:29 +01:00
andsel 12a3c65c9b Fixed javadoc (issue #164) 2017-01-04 12:52:42 +01:00
andsel 480e36579c Fixed NPE exception of inflight ACK because the publisher with clean=true removed all messages, also the published from message store 2017-01-04 11:17:30 +01:00
andsel 2c43c74fe3 Added gracefull handling when client cut TCP connection 2017-01-04 11:13:58 +01:00
andsel 4029ddd2b1 Removed ClasspathConfig to use the ClasspathResourceLoader and basic ResourceLoaderConfig 
Removed FilesystemConfig to use the FileResourceLoader and basic ResourceLoaderConfig
 2016-12-31 19:30:41 +01:00
andsel 0f41c9ea08 Changed default behaviour to use persistent sotre, now use in memory as default and not FS moquette.mapdb (Fix issue #242) 2016-12-31 16:06:18 +01:00
andsel a146ffb30e Minor changes to distribution's log4j config file to include the messagelog logger 2016-12-31 15:28:06 +01:00
andsel dd61be59b3 Switched from http encoder and decoder to codec, and fixed logger to check message type before log 2016-12-30 00:33:10 +01:00
andsel ac2086a0e0 Fixed failing test due to more strict endpoint check from Netty 4.1.x 2016-12-30 00:33:10 +01:00
Andrea Selva ea043bc743 Merge pull request #246 from nemecec/fix-deps 
Remove compile-time dependency on log4j
 2016-12-29 14:59:38 +01:00
Andrea Selva 3dce95cc50 Merge pull request #245 from nemecec/patch-1 
MessageDigest is not thread-safe
 2016-12-29 14:59:19 +01:00
andsel 1ad5f4aef9 Added MQTT message logger 2016-12-28 22:22:55 +01:00
andsel db7a597bcc Fixed timeout in test 2016-12-28 22:22:27 +01:00