anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
672 Commits 2 Branches 127 Tags
0b5c95ee577b253361834867ed2b3c8349bab93a
Commit Graph
100 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
Andrea Selva 0b5c95ee57 Merge pull request #121 from sboorlagadda/ISSUE-120 
deleted the file in teardown
 2015-10-27 22:55:46 +01:00
andsel 165a0aebd5 Removed unusefull SubscriptionsStore.clearAllSubscriptions used only in tests 2015-10-17 21:08:06 +02:00
andsel 1d25839f53 Refactory, moved SubscriptionStore related method directly in the subscriptioStore from ProtocolProcessro 2015-10-17 20:43:53 +02:00
andsel a7aba651b8 Fixed bug #108, remove of clientID for a stolen session the new session get immediately removed 2015-10-17 18:52:04 +02:00
andsel c96ce9d37e Minor, used project.version where possibile to simplify the poms 2015-10-17 13:18:05 +02:00
Andrea Selva afd710fccc Merge pull request #117 from wagnerluis1982/master 
Set maven POM version as constant (fix issue #112)
 2015-10-17 13:05:35 +02:00
andsel 85872eec19 Changed SubscriptionsStore overall tree (ones based on clientID) operations to copy all the tree 2015-10-10 19:16:30 +02:00
andsel ef9af6edae Minor change, removed unused method 2015-10-10 16:18:25 +02:00
andsel b35eb9ec81 Removed back ringbuffer 2015-10-05 21:25:30 +02:00
andsel 54c68a61c0 Added timeout check during shutdown of MapDB storage 2015-09-30 22:12:36 +02:00
andsel 6ab413de68 Fixed server shutdown, it doesn't flushed the MapDB to disk 2015-09-30 21:41:55 +02:00
andsel 7fb9d2d55a Removed commented code 2015-09-29 22:29:25 +02:00
andsel f45c0a76e1 Changed the subscription tree to work as persistent tree 2015-09-29 22:29:25 +02:00
andsel 46f9a38056 Removed frot ringbuffer (old isolation from Netty's thread and single protocol processor thread) 2015-09-29 22:29:24 +02:00
andsel b7169271ac Moved test of MapDBPersistenceStore into the test unit 2015-09-29 22:07:45 +02:00
andsel 9effc1edb5 Minor change 2015-09-29 21:44:35 +02:00
andsel a697e77e6c Minor change 2015-09-29 21:41:58 +02:00
andsel db6d296c20 Minor change 2015-09-29 21:39:32 +02:00
andsel 3e37df1275 Renamed addInFlight and cleanInFlight to be related to temp messages, not really relate to in-flight 2015-09-29 21:19:11 +02:00
Andrea Selva 76bdd00a18 Merge pull request #107 from kazvictor/Server-Shutdown-Test-and-Fix 
Stopping the persistence commit scheduler in MapDBPersistentStore when it is closed
 2015-09-29 21:08:58 +02:00
andsel cc4b3715c5 Minor change, avoid to remove and add to the Netty's pipeline the MoquetteIdleTimoutHandler 2015-09-24 12:05:50 +02:00
andsel ea2daa688f Merge branch 'master' of github.com:andsel/moquette 2015-09-24 11:31:20 +02:00
Andrea Selva 4e32988661 Merge pull request #106 from kazvictor/QOSType_encode_decode_fixes 
Fixing QOSType encoding and decoding of FAILURE qos (0x80).
 2015-09-24 11:30:45 +02:00
andsel 5e397ea6d9 Minor change, just changed log level in PublishDecoder 2015-09-23 17:05:48 +02:00
andsel ca99a00ac2 Minor, fixed a shutdown exception 2015-09-23 12:22:00 +02:00
andsel 33bc23b4e1 Added null check to fix issue #93 2015-09-22 15:55:52 +02:00
andsel 67087a6a7e Minor changes 2015-09-22 15:52:12 +02:00
andsel fae4685082 Added subprotocol specs for MQTT over WebSocket (fix issue #90) 2015-09-22 15:47:34 +02:00
andsel f7466fd968 Added check to avoid creation of LostConnectionEvents for not yet completed connects (fix issue #88) 2015-09-22 15:29:23 +02:00
Andrea Selva 56f122b8b9 Merge pull request #103 from runafter/issue-91 
Fix multiple client connection using SSL issue #91
 2015-09-22 11:35:27 +02:00
andsel 573bf273ff Published old committed on local branch changes (fix for issue #79) 2015-09-20 14:27:06 +02:00
andsel 6e1524817e Fixed ugly empty session storage, avoid fake NullObject empty subscription subscription 2015-09-20 14:10:28 +02:00
andsel f1e2aff331 Minor, splitted ProtocolProcessorTest into 2 sub TestSuites 2015-09-20 11:31:59 +02:00
andsel e68a485e16 Minor added check fake issue #87 2015-09-19 19:58:05 +02:00
andsel e08cf95135 Changed willMessage and password in CONNECT message from String to byte[] (fix issue #94 and #95) 2015-09-16 23:25:15 +02:00
andsel 9a7ec7fd62 Minor change, just aligned ChangeLog 2015-09-16 22:57:28 +02:00
andsel 05446ddf1a Minor change, just added MapDB groovy toy script 2015-09-16 22:21:15 +02:00
Andrea Selva de642bf3e6 Merge pull request #89 from kazvictor/PubRelEncodeFix 
PubRelEncoder to encode following MQTT specification
 2015-08-25 22:14:51 +02:00
andrea d8875dd8b9 Moved config part in its separate package 2015-08-22 15:40:55 +02:00
andrea 560559fad2 Abstracted configuration part to use filesystem or classpath files 2015-08-22 15:35:11 +02:00
andrea b6554eb0ac Added simple main class to test embedding of Broker 2015-08-18 23:59:45 +02:00
andrea fdbee3a21f Added shutdown sequence of the disruptor used in the output part (from ProtocolProcessor down to the cable) 2015-08-18 23:54:24 +02:00
Andrea Selva 28b7529516 Merge pull request #85 from wagnerluis1982/master 
Encapsulating every intercept data
 2015-08-18 18:09:33 +02:00
andrea 89790291a5 Minor change, updated Netty and MapDB versions 2015-08-10 23:23:43 +02:00
andrea bafcca4c58 Added checking of valid topicFilter format in unsubscribe 2015-08-10 23:07:47 +02:00
andrea 74aaf603e2 Fixed issue #69 2015-08-09 12:16:58 +02:00
andrea c3224c2a5b Minor change, updated copyright to 2012-2015 2015-08-08 19:36:14 +02:00
andrea 68ac417f65 From cloning of Publish and Connect messages to unmodifiable copies 2015-08-08 19:26:27 +02:00
andrea 0c114d3dab Minor changed, fixed typo in method name (ProcotolVersion to ProtocolVersion) 2015-08-08 19:03:27 +02:00
andrea ccc5ceb3b9 Switched from cloning of ConnectMessage to unmodifiable with copy construtor 2015-08-08 19:02:48 +02:00
andrea dc55ff4078 Removed never used and unsufull no-op interceptor, forced usage of BrokerInterceptor, changed BrokerInterceptor to work on a list of InterceptHandler 2015-08-08 18:37:32 +02:00
andrea 9daff2b738 Removed unsufull classes and moved out of internal broker structures the firing of interceptor events 2015-08-08 11:29:58 +02:00
Andrea Selva f876ae49ad Merge pull request #76 from wagnerluis1982/master 
Accepted but ha to be reworked on the master
 2015-08-08 09:56:36 +02:00
Andrea Selva b644d560d8 Minor change, fix issue #74 2015-08-03 18:05:25 +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 14f14e20df Minor, added authorizator and autheticator class variables in the config used in distribution 2015-07-23 19:56:48 +02:00
andrea 4a7c90e5bc Minor, added null check on user and password in FileAuthenticator 2015-07-23 19:26:38 +02:00
andrea 90cf8eabd8 Minor, added Luca Capra as contributor 2015-07-23 16:25:02 +02:00
andrea e690f97c8d Bumped dev cycle for version 0.8 2015-07-23 16:22:34 +02:00
Andrea Selva 5860a5a027 Merge pull request #72 from muka/patch_auth 
Added authorizator and authenticator class load in config
 2015-07-23 16:21:04 +02:00
andrea f0a8346ef4 Bumped verision 0.7 2015-07-08 19:54:29 +02:00
Andrea Selva a1fb2115cd Merge pull request #64 from salmanebah/fix-window-moquette-script 
Updated the windows script
 2015-07-08 19:16:59 +02:00
andrea 4663fa507b Introduced WSS to fix issue #8 2015-06-30 22:44:22 +02:00
andrea f2410f962b Extracted SSLHandler initialization into separate method 2015-06-30 22:15:32 +02:00
andrea ac2eb6dce0 Fixed bad qos publish, issue #56 2015-06-28 19:53:22 +02:00
andrea b8af814940 Changed Subscription equals to use also cleanSession flag in equality check 2015-06-28 16:26:10 +02:00
andrea 5416a87149 Anticipated credentials check before dropping an already connected clientID 2015-06-28 15:31:21 +02:00
andrea 7dece38b57 Fixed multiple publish notification for overlapping subscriptions (fix issue #52) 2015-06-23 23:23:38 +02:00
andrea 336c452ef3 Added remove of subscribed topic during processing of UNSUBSCRIBE message (fix issue #50) 2015-06-21 17:49:39 +02:00
andrea 78b3f1faf8 Minor change, removed redundant parameter in method addNewSubscription of session storage 2015-06-21 16:37:44 +02:00
andrea 932d2fb4cb Fixed issue #49, duplication of subscription with different QoS 2015-06-21 15:55:39 +02:00
andrea 3deb903f3c Minor change, modified dumpTree to graphicaly show a tree 2015-06-21 15:36:41 +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 c4ebd75008 Minor change, moved method argument from exploded arguments to carrier object 2015-06-20 15:52:00 +02:00
andrea 92a76c9de1 Fixed issue #38, autoboxing of a nullable Integer given a default to 0 assignment 2015-06-20 12:17:50 +02:00
andrea d20940f110 Minor fixed badly double inserted "metrics" handler in Netty pipeline 2015-06-16 23:21:49 +02:00
andrea a3f06f7e33 Reenabled the logging of bytes moved 2015-06-16 23:08:26 +02:00
andrea 5f73cded22 Fixed issue #41 memory leak on metrics collectors 2015-06-16 22:43:55 +02:00
andrea e699d5ff2b Fixed issue #40 2015-06-07 17:57:42 +02:00
andrea 3f4a5586de Fixed mem leak due to caching of object without hasCode (NettyChannelContext 2015-06-07 17:47:50 +02:00
andrea 3ceabfabdd Fixed issue #42 rollbacked to MapDB 1.0.7 2015-06-03 23:30:53 +02:00
andrea 47d1f94a13 Added self contained client benchmarker usgin fuse, measure the complete roudtrip 2015-06-03 22:35:28 +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 d1a8a79525 Added integration script to reproduce issue 42 2015-05-27 23:05:52 +02:00
andrea 53aa74b493 Minor change, extracted some commonly used code 2015-05-26 23:11:55 +02:00
andrea 78eddadac4 Added user substitution during ACL pattern mathing 2015-05-26 22:51:16 +02:00
andrea db4b7ca192 Added trivial implementation of ACL patterns 2015-05-26 22:40:34 +02:00
andrea 092e30a552 Minro change, added global to user specific cascading 2015-05-26 00:09:27 +02:00
andrea 059fd89b69 Implemented the part of parsing and accessing the user specific ACLs 2015-05-26 00:06:22 +02:00
andrea 9a97b00750 Minor change, removed unusefull ParseExeptions logging 2015-05-20 23:38:15 +02:00
andrea 443bf7ab85 Refactored the collection of all ACL in a specialized collector class instead of using plain List 2015-05-20 23:34:42 +02:00
andrea 1aecc3d922 Added check on read access (in publish) 2015-05-20 21:53:13 +02:00
andrea 75e67dcbd0 Minor change, documented the content of config files 2015-05-20 21:28:36 +02:00
andrea 302f3a96ce Fixed the configuration of acl_file path 2015-05-19 23:15:44 +02:00
andrea 8b8058dc47 Added basic initial implementation for ACL validation 2015-05-19 22:07:57 +02:00
andrea f3ed351c61 Added plumbing code to use the concept of Authorizator into publish semantic 2015-05-17 16:24:37 +02:00
andrea 6d3fbc4591 Implementd basic parsing fro ACL lines 2015-05-17 12:34:46 +02:00