Commit Graph
1000 Commits
Author SHA1 Message Date
andsel 4790325f0e Added MapDP perf test groovy script 2016-09-12 12:39:43 +02:00
andsel 181303b58b Merge branch 'master' of github.com:andsel/moquette 2016-09-12 12:29:01 +02:00
andsel 55ea2d7c12 Added lab experiment to check H2 MVStore perf 2016-09-12 12:28:55 +02:00
Andrea Selva 40f2d87434 Merge pull request #202 from FraunhoferIOSB/Bugfix-PersistenceFileLock
Bugfix for ServerRestartIntegrationTest - Persistence file could not be deleted under Windows
2016-08-19 09:00:57 +02:00
Jacoby 36daf153db * Bugfix - persistence file could not be deleted under Windows because it was in use by the server 2016-08-18 16:20:14 +02:00
Andrea Selva 8b7458a6c4 Merge pull request #191 from kevto/hotfix/allow-zero-byte-clientid
Allow zero byte client identifiers in the connect message.
2016-08-07 22:29:56 +02:00
Andrea Selva 3c614910e5 Merge pull request #192 from kevto/hotfix/anonymous-invalid-close-connection
Closing connection on non-zero return code in CONNACK packet.
2016-08-07 22:15:33 +02:00
Kevin Berendsen 807debb622 Terminating the connection if the client failed to receive a CONNACK packet with a non-zero return code. Stated in 3.2.2.3 of MQTT 3.1.1 specificaton.
Was checking the wrong channel to see if it was still open or not. The channel that the test was checking on was disconnected a few lines above.
2016-08-07 13:34:06 +02:00
Kevin Berendsen bc6525e431 MQTT3.1.3-6 stated that the client can connect without giving up an client identifier. However, the broker should generate one for the client id as of the client gave the identifier to broker. The client will now disconnect if the client hasn't given up an identifier with clean session set to 0. Done this regarding issue #190
NettyChannelAssertions class has been modified so you could add a message to the assertion.

Unit tests have been added to test the modified processConnect() method.

The server can allow zero byte client identifiers through moquette configuration.
2016-08-07 13:17:41 +02:00
andsel 32b6b9b1da Minor, renamed SimpleMessaging to ProtocolProcessorBootstrapper 2016-07-22 13:32:25 +02:00
andsel 8cc588d766 Simplyfied creation of HazelcastMsg from InterceptPublishMessage 2016-07-22 13:19:16 +02:00
andsel 29fd6d03b9 Minor refact in HZ configuration 2016-07-22 13:08:48 +02:00
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
kevto 486b4fe8ba Moved the overrideSubscription test from SubscriptionsStoreTest to a new test case named ClientSession. Removed a parameter in ClientSession.subscribe method. topicFilter param had no use but for logging purposes. 2016-07-17 14:24:19 +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
IODBEEC1 ed9d91e527 add/remove InterceptHandlers with server running 2016-07-09 09:09:57 +02:00
andsel 1ef2a4fd3c Minor change, remove a redundant ClientID param from verifyToActivate method 2016-07-02 12:30:19 +02:00
mackristof 2dd18c2b70 fix(cluster): change HazelcastMsg payload to byte[] 2016-06-28 22:07:54 +02:00
mackristof eec4dc1779 feat(cluster): add default clustering feature 2016-06-28 17:27:35 +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
Martin Crawford d622adb4ef Add clientID parameter to the IAuthenticator interface (breaks compatibility). 2016-06-26 10:01:15 -04: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
chris-lumigrow 04303eda75 changes order of m_properties assignment in Constructors such that the 'assignDefaults' data is NOT overwritten by the incoming values 2016-05-18 00:11:18 +02:00
chris-lumigrow 4bf2f60f42 commit failing test for ClasspathConfig's null pointer issue 175 2016-05-18 00:11:18 +02:00
chris-lumigrow b5b16b5dff allows empty string as well as null to force not listen on port, also allows turn off of nonSSL MQTT listener 2016-05-18 00:11:18 +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
mackristof 4bcecd5aa3 Added integration of DBAuthenticator & integration test with H2 DB 2016-05-13 16:43:08 +02:00
mackristof cad1165071 Added DBAuthenticator & Test with H2 DB 2016-05-12 15:47:49 +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
chris-lumigrow 9fec341589 fix CSV list bug, collect CSV list into constant, provide better logging on disabled SSL 2016-05-03 18:55:17 -07: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
Dee Eldredge 1e7f6d98e7 Based on feedback, renamed messageConsumed -> messageAcknowledged. 2016-03-23 23:11:09 +01:00
Dee Eldredge 1b77e43b61 Added topic to consumed message. 2016-03-23 23:10:45 +01:00
Dee Eldredge 7dab8a367f Added username to all messages. From a consumer perspective the username is more useful than a clientID which is often autogenerated. 2016-03-23 23:10:24 +01:00
Dee Eldredge f44283d5f0 Added onMessageConsumed logic.
Related to:  https://github.com/andsel/moquette/issues/156
2016-03-23 23:09:16 +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