andsel
a54b122094
Substituted complex test to check lowering of qos level to the same accepted on subscription time
2016-12-13 23:43:02 +01:00
andsel
296af8b4f6
Renamed route2Subscribers() to publish2Subscribers()
2016-12-13 23:43:01 +01:00
andsel
3355e7c334
Moved selection of subscriptions out of route2Subscribers
2016-12-13 23:43:01 +01:00
andsel
b6239b3c5c
Changed SUBSCRIPTION processing to be based on concurrent FSM
2016-11-27 21:35:20 +01:00
andsel
38746ad0dd
Moved existing CONNECT processing to an FSM
2016-11-27 21:35:20 +01:00
andsel
7508275cf7
Changed the way a Client session is active and moved to event and states of Channel for CONNECT and DISCONNET messages
2016-11-05 18:29:08 +01:00
Andrea Selva
ccdb50e760
Merge pull request #224 from bcw104/master
...
broker: notify when client connection lost
2016-11-05 17:08:09 +01:00
bcw
3e89bc5d2c
notify when client connection lost；
...
implement onConnectionLost() method in AbstractInterceptHandler.java;
2016-10-24 11:37:10 +08:00
teranisi
81a1d8d2b2
Add 'getSubscriptions' API on Server.
...
Add a test for sessions without clean session flag.
2016-10-20 14:23:57 +09:00
andsel
912a88ec0a
Minor, switched from .replace to .put (JDK 1.7 compatibility)
2016-09-23 12:10:42 +02:00
andsel
8215e89d77
Changed String for guids to its value object
2016-09-23 11:51:25 +02:00
andsel
ac5a4daa6f
Changed the way of create MapDB's messages and session stores, it's now more coupled (they are the same stuff at the end)
2016-09-23 10:11:50 +02:00
andsel
4d637a349b
Fixed drop messages in clean session phase, introduced ref counter
2016-09-23 09:45:47 +02:00
andsel
5efad350d8
Fixed the configuration of HZ for local tests to avoid multicast preferring tcp local address
2016-09-12 17:49:40 +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
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
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
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
mackristof
eec4dc1779
feat(cluster): add default clustering feature
2016-06-28 17:27:35 +02:00
Martin Crawford
d622adb4ef
Add clientID parameter to the IAuthenticator interface (breaks compatibility).
2016-06-26 10:01:15 -04: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
4bf2f60f42
commit failing test for ClasspathConfig's null pointer issue 175
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
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
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
Dee Eldredge
1e7f6d98e7
Based on feedback, renamed messageConsumed -> messageAcknowledged.
2016-03-23 23:11:09 +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
andsel
9b75a6a0a9
Fixed failing test
2016-03-06 20:02:10 +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
Michael Konrad
f5a3d57afd
Enables client authentification for SSL
...
Client authentification can be set as with the SSL Properties to
require the client certificate to be signed by the server.
Added jUnit test and test certificates
2016-02-17 12:02:52 +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
8c14efb7d8
Added integration test to check issue #142
2016-01-30 11:46:06 +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