anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
788 Commits 2 Branches 127 Tags
81100e13b448251e05526c5e90599e01f5a46c75
Commit Graph
100 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
andsel 81100e13b4 Switched to HZ 3.5.4 2016-07-22 12:43:12 +02:00
Andrea Selva 3085ee54d8 Merge pull request #189 from andsel/mackristof-feat/cluster 
Mackristof feat/cluster
 2016-07-22 12:13:16 +02:00
andsel fedd2965cc Fixed Hazelcast itnegration tests, removing unusefull thread sleeps, but more important permitting the co existence of 2 Brokers in the same JVM 2016-07-22 12:09:10 +02:00
andsel 7886bf7103 Merge branch 'feat/cluster' of https://github.com/mackristof/moquette into mackristof-feat/cluster 2016-07-21 16:17:15 +02:00
Andrea Selva 6a4aa28489 Merge pull request #188 from kevto/hotfix/client-session-subscribe 
One param less in ClientSession subscribe method
 2016-07-18 21:40:09 +02:00
Andrea Selva 3d2e69cc21 Merge pull request #187 from iodb/master 
add/remove InterceptHandlers with server running
 2016-07-10 11:22:44 +02:00
andsel 1ef2a4fd3c Minor change, remove a redundant ClientID param from verifyToActivate method 2016-07-02 12:30:19 +02:00
Andrea Selva 8fceb20a9e Merge pull request #185 from bemisguided/master 
Add clientID to the IAuthenticator interface
 2016-06-28 13:08:22 +02:00
andsel 693a9a454f Fixed bug, missed insertion into flight zone of QOS1 messages 2016-06-18 12:21:21 +02:00
andsel 0c4f7fa393 Refactored the part of move from inFlight to second stage rel ack, this driven to missed notification to the interceptors 2016-06-16 23:01:48 +02:00
andsel d5399995c3 Regenerated some keystore used in tests with commands described in ServerIntegrationSSLClientAuthTest.java 2016-05-29 21:31:49 +02:00
andsel e41e55f5aa Added the 'disabled' keyword in config to disable a listener on a port 2016-05-18 00:11:19 +02:00
andsel 5f003ccb05 MOved conenct method into the test support class Client 2016-05-18 00:11:18 +02:00
Andrea Selva d396edad12 Merge pull request #178 from mackristof/master 
Authentication on DB storage
 2016-05-16 22:23:00 +02:00
Andrea Selva d24f14a8f2 Merge pull request #173 from windbender/master 
Collect CSV list into constant, provide better logging on disabled SSL
 2016-05-04 13:38:44 +02:00
andsel dbe9c7bcaa Added integration test to check firing of will message (issue #171) 2016-05-02 20:48:18 +02:00
andsel 5029da8763 Removed WebSocket port from default configuration, end moved defaults config from ConfigParser to Config container. Fixes isse #150 2016-04-25 11:52:07 +02:00
andsel ae734ded8e Fixed ProtocolProcessor with bad merged code 2016-03-23 23:24:54 +01:00
andsel ed6ad315d1 Fixed merge 2016-03-23 23:13:01 +01:00
Andrea Selva 0b883d1f9a Update README.md 2016-03-23 22:48:50 +01:00
Andrea Selva 48031dd6da Update README.md 2016-03-23 22:47:37 +01:00
Andrea Selva f32c8f5fe6 Minor change, moved upstairs the Google group ref 2016-03-23 22:46:27 +01:00
andsel 9b75a6a0a9 Fixed failing test 2016-03-06 20:02:10 +01:00
andsel cd908f7e44 Added memory queue to before pushing to Netty, first step to have a persistent queue per channel 2016-03-06 19:50:47 +01:00
andsel 4e8f72a34b Moved test to use a test client callback that queue up all received messages 2016-03-06 19:50:47 +01:00
andsel 6cadaebb0c Minor, rewritten test to user Paho instead of fusesource mqtt client 2016-03-06 19:50:47 +01:00
andsel efbfab7914 Minor, moved tests from ServerIntegrationFuseTest to ServerIntegrationPahoTest to limit the usage of fusesource mqtt client 2016-03-06 19:50:47 +01:00
andsel 7bb02d9a2a Defined attribute for package to OSS Sonatype, and to GPG sign the artifacts 2016-03-06 19:50:47 +01:00
Andrea Selva 1604c71c33 Merge pull request #149 from konradmichael/clientAuth 
Enables client authentification for SSL
 2016-02-29 13:35:34 +01:00
Andrea Selva 368100f77c Merge pull request #148 from redsolo/master 
Unable to find org.eclipse.paho.client.mqttv3 dependency
 2016-02-06 10:51:40 +01:00
andsel 62c5985a34 Fixed merged dep 2016-02-03 23:31:58 +01:00
andsel 91505c9350 Fixed dependency 2016-02-03 23:28:38 +01:00
andsel 5487303095 Merged parser_commons into netty_parser 2016-02-03 23:20:15 +01:00
andsel 5c7e2b357f Fixed missed clean session for ClientSession, issue #145 2016-02-02 22:39:11 +01:00
andsel d36de24349 Minor, modified access to fields of SubscribeMessage.Couple 2016-01-30 17:35:28 +01:00
andsel a19af18a61 Moved read authorization check from publish phase to subscribe 2016-01-30 17:22:17 +01:00
andsel 69c1219f2b Minor added source and javadoc jars creations 2016-01-30 11:54:17 +01:00
andsel 8c14efb7d8 Added integration test to check issue #142 2016-01-30 11:46:06 +01:00
andsel 25b6413be1 Minor, removed unused map in MapDBMessagesStore 2016-01-30 11:05:03 +01:00
andsel dfa75e145f Fixed bug #143 avoid publication try to disconnected clients 2016-01-25 22:21:38 +01:00
andsel 43f7223a15 Minor refactory, renamed var names from session to channel 2016-01-24 19:21:24 +01:00
andsel 3be2667844 Minor refact, moved Channel's attributesKey accessible by utils methods 2016-01-24 19:21:24 +01:00
andsel 43371d3068 Minor refact, moved commons Channel attributes constants from NettyChannel to NettyUtils 2016-01-24 19:21:24 +01:00
andsel aa94d47148 Minor change, removed commented code 2016-01-24 19:21:24 +01:00
andsel 7b1db3e1db Refactoring, dropped unuseful ServerChannel abstraction in favor on Netty's Channel 2016-01-24 19:21:24 +01:00
andsel beb556c73c First clean of Moquette's channel abstraction to user Netty's one 2016-01-24 19:21:24 +01:00
andsel c7e82497dd Updated version path to download the artifact 2016-01-21 22:47:15 +01:00
andsel ff93fcdc9c Changed BinTray name from org.dna.mqtt to io.moquette to let the artifacts be pushed on JCenter 2016-01-21 22:44:36 +01:00
andsel 5b6d0ced6e Bumped dev cycle for 0.9-SNAPSHOT 2016-01-17 13:32:14 +01:00
andsel a44d6b09a8 Bumped release 0.8 2016-01-17 13:04:45 +01:00
andsel 4c1f36cf67 MOved the method nextClientID from IMessagesStore to the ISessionsStore because it's session related 2016-01-17 13:00:36 +01:00
andsel 5daf1362cc Rollback issue #130 because the remove from the inflight is done by MapDBSessionsStore.inFlightAck 2016-01-17 12:29:55 +01:00
andsel cf252da519 Minor change, added loggin for testing ProtocolDecodingServer 2016-01-03 17:29:44 +01:00
andsel 5f83465529 Removed a queue per client of inFlightIds (never cleaned) in favor of single atomic generator, fixes issue #130 2016-01-02 16:43:12 +01:00
andsel 9c8e96df16 Minor change 2016-01-01 17:22:09 +01:00
andsel 163858e47b Fixed bug in deletion of valid conn descriptor once different clients with same ID connects (issues #116 and #124) 2015-12-27 13:19:16 +01:00
Andrea Selva 571eaa1378 Merge pull request #135 from stannislin/master 
Change the executing name of class in moquette.sh
 2015-12-22 16:40:32 +01:00
andsel 8e891da49f Removed client active/not active state from persistence (issue #118) 2015-12-19 18:01:54 +01:00
andsel 4f65a59324 Minor change, upgraded mqtt-client from Fuse to 1.12 2015-12-19 17:58:27 +01:00
andsel 446c846572 Exposed the a Server.start method to injiect IAuthenticator and IAuthorizator to be embedded (fix issue #114) 2015-12-13 17:01:23 +01:00
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