Commit Graph
290 Commits
Author SHA1 Message Date
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
Victor Kazakov a9404bdf31 Stopping the persistence scheduler in MapDBPersistentStore when it is closed. Adding a test to make sure all threads get stopped when the broker is stopped. 2015-09-25 11:39:24 -07: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
Victor Kazakov 767e2ba4b7 Fixing QOSType encoding and decoding of FAILURE qos (0x80). This was causing bug with decoding a SubAck with failure qos type. See Appendix B: MQTT-3.9.3-2 2015-09-23 16:30:40 -07: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
runafter 709f6d7c4a Fix multiple client using SSL issue #91 2015-09-22 13:34:18 +09: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 05446ddf1a Minor change, just added MapDB groovy toy script 2015-09-16 22:21:15 +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
Wagner Macedo 96c63b5e6f Encapsulating every intercept data
- Removed UnmodifiableConnectMessage and UnmodifiablePublishMessage
  classes.
2015-08-17 17:54:08 -03: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
Wagner Macedo 8a3fa2956c Added unit tests for interceptor 2015-08-02 12:40:15 -03:00
Wagner Macedo 67ed07549e Makes interceptor notify handler asynchronously 2015-08-02 12:40:11 -03:00
Wagner Macedo 58f6191a8e Assure intercept methods to not change the message
This was done by cloning.
2015-08-02 09:34:12 -03:00
Wagner Macedo 66ce5b6e0e Enabling ability for interception of broker events 2015-08-02 09:34:11 -03:00
andrea 5bfc73fafb Minor changes 2015-08-01 16:45:28 +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 e690f97c8d Bumped dev cycle for version 0.8 2015-07-23 16:22:34 +02:00
Luca Capra 5a362aa8f9 Merge tag '0.7' into patch_auth
Version 0.7 MapDB migration
2015-07-23 15:54:14 +02:00
Luca Capra 9e7f2b76f7 fix getInstance label typo 2015-07-23 15:52:56 +02:00
andrea f0a8346ef4 Bumped verision 0.7 2015-07-08 19:54:29 +02:00
Luca Capra ea98ccb8f1 add classloader tests 2015-07-06 18:35:31 +02:00
Luca Capra 44f51e5e60 allow to load class instance with getInstance 2015-07-06 18:18:56 +02:00
Luca Capra f4ec180d85 added config options for authorizator_class and authenticator_class 2015-07-06 16:37:42 +02:00
andrea 4663fa507b Introduced WSS to fix issue #8 2015-06-30 22:44:22 +02:00