anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
709 Commits 2 Branches 127 Tags
f44518ff27ea5723de1eb295316f15b983eb33f4
Commit Graph
100 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
andsel f44518ff27 Moved security SPI related interfaces into dedicated package 2015-12-13 16:42:04 +01:00
andsel 51627ea2f6 Added ISslContextCreator method argument to Server.startServer to use embedded SSL certificates (fix issue #115) 2015-12-13 16:36:47 +01:00
andsel b280089225 Minor changes, fixed a type in method name 2015-12-13 14:08:56 +01:00
andsel db66f19109 Added sleep in integration tests to let MQTT clients finish it's job when we need a serial behaviour 2015-12-08 19:46:43 +01:00
andsel 6cb67eb6c8 Fixed integration tests for internal publish 2015-12-08 19:27:47 +01:00
andsel 16a5556fa3 Added internal publish once the broker is embedded in hosting applications 2015-12-08 18:12:00 +01:00
andsel 6805cf89ee Minor change, just renames 2015-12-08 15:15:51 +01:00
andsel 8c88567c78 Minor change, moved const definition from Constants inside parser-commons to BrokerConstants inside broker project 2015-12-08 14:04:35 +01:00
andsel f41f7dafb9 Added sample publish InterceptHandler implementation to EmbeddedLauncher (#104 publish listner part) 2015-12-08 12:07:03 +01:00
andsel 5a1cd97b71 Removed clean session flag from subscription and moved in the correct place (ClientSession) 2015-12-06 19:55:04 +01:00
andsel 80569d5dfe Minor change, added a factory method for ClientTopicCouple built from Subscription 2015-12-06 19:31:36 +01:00
andsel 585bf7523e Minor chane, fixed integration scripts for many connections 2015-12-06 19:04:26 +01:00
andsel 9ce9a6597f Architechtural refactory, moved subscription out of tree and into db store 2015-12-06 11:43:29 +01:00
andsel 490c6a763d Adapted issue #79 integration tests scripts to be used for #119 2015-12-01 23:20:51 +01:00
andsel 7325c8e7bc Minor, cleaned imports 2015-12-01 23:00:42 +01:00
andsel 1cc1807aec Removed excessive dump trees, lowered to trace level 2015-12-01 23:00:23 +01:00
andsel 810d8a1af8 Removed TreeNode's parent reference to avoid maintaning a reference that could keep live big trees (solves #119 and #126) 2015-12-01 22:59:38 +01:00
andsel e3b6391653 Added 'autosave_interval' fix issue #97 2015-11-22 16:56:40 +01:00
andsel 72f628888e Minor change 2015-11-20 21:36:52 +01:00
andsel 371c740321 Moved project package from org.eclipse.moquette to io.moquette 2015-11-20 21:30:59 +01:00
andsel f438ef7f49 Separated ISessionsStore and IMessagesStore Memory implementations 2015-11-19 00:16:18 +01:00
andsel 892eecfa2b Separated ISessionsStore and IMessagesStore MapDB implementations 2015-11-19 00:15:43 +01:00
andsel 9f9d01ec58 Changed retained persistence to use the global message store and guids, instead of duplicate msg contents 2015-11-18 22:25:14 +01:00
andsel faf1abb896 Cleanup of unused classes 2015-11-17 21:47:04 +01:00
andsel fdf5b03983 Removed no more used methods 2015-11-16 23:53:10 +01:00
andsel 9236def453 Used the message store for QoS2 messages 2015-11-16 23:45:47 +01:00
andsel dbf86c9408 Minor change, removed commented code 2015-11-15 13:27:35 +01:00
andsel 7fb9198373 Fixed missed store/load of guid for StoredPublishEvent 2015-11-15 13:21:28 +01:00
andsel 02b23ef926 Fixed bad client session load on republish 2015-11-15 12:55:30 +01:00
andsel 2cd6077287 Fixed packetId missed cleanup 2015-11-15 12:54:30 +01:00
andsel 191a94e19d First refactoring using the concept of ClientSession also for publish 2015-11-15 11:16:18 +01:00
andsel ce1618cb52 Minor changes, refactored ConnectionDescriptor to be an immutable object 2015-11-10 22:24:35 +01:00
andsel 608a72d3ac Minor change, removed unused reference 2015-11-08 18:42:03 +01:00
andsel 19dac6e32b Refactored the disconenct and clean of session to use new ClientSession 2015-11-08 18:42:03 +01:00
andsel 635c87389d Refactored ProtocolProcessor.processUnsubscribe to use the ClientSession concept instead of direct access to map storage 2015-11-08 18:42:03 +01:00
andsel 9a18739a7f Refactored ProtocolProcessor.processSubscribe to use the ClientSession concept instead of directe access to map storage concepts 2015-11-08 18:42:03 +01:00
andsel c793ded63e Introduced 'fat' ClientSession class responsible to model the concept of an MQTT client session 2015-11-08 18:42:03 +01:00
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