anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
986 Commits 2 Branches 127 Tags
a1dd6132327c9a9381cd761ab8a4a7e747d32036
Commit Graph
197 Commits
Author SHA1 Message Date
Andreas Mager a1dd613232 broker/ClasspathResourceLoader: code formatter used 2017-02-01 17:13:37 +01:00
Andreas Mager f5d74d8d0e broker/ServerAcceptor: code formatter used 2017-02-01 17:13:37 +01:00
Andreas Mager 19a200707b broker/Server: code formatter used 2017-02-01 17:13:37 +01:00
Andreas Mager a156a1d084 broker/HazelcastListener: code formatter used 2017-02-01 17:13:37 +01:00
Andreas Mager 4236bc2af5 broker/Constants: code formatter used 2017-02-01 17:13:37 +01:00
Andreas Mager 36c09c02ab broker/ConnectionDescriptorStore: code formatter used 2017-02-01 17:13:37 +01:00
Andreas Mager 5c9d0808dd broker/ConnectionDescriptor: code formatter used 2017-02-01 17:13:37 +01:00
Andreas Mager 6821548d50 broker/LoggingUtils: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager a198247d13 broker/InterceptUnSubscribeMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 255eed49a7 broker/InterceptSubscribeMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 6cdcee0c58 broker/InterceptPublishMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 96df597507 broker/InterceptMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 5054c72b32 broker/InterceptDisconnectMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 16ee560f4c broker/InterceptConnectMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 73bce495e1 broker/InterceptConnectionLostMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 25bb6f50a5 broker/InterceptAcknowledgedMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager fdce1bbc59 broker/InterceptAbstractMessage: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager 48afd160d5 broker/Interceptor: code formatter used 2017-02-01 17:13:36 +01:00
Andreas Mager c48534b0ba broker/InterceptHandler: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager e81f8ff96c broker/HazelcastMsg: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager 2d9f93bdf8 broker/HazelcastInterceptHandler: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager 65ba222b89 broker/AbstractInterceptHandler: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager 1d89578ab5 broker/MqttSubscription: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager 852a87a516 broker/MqttSession: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager 8aa4a77c4a broker/MqttConnectionMetrics: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager d72b2611d7 broker/IConnectisoManager: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager 4ea5d290c7 broker/BrokerConstants: code formatter used 2017-02-01 17:13:35 +01:00
Andreas Mager 526bcc61cf broker/DefaultMoquetteSslContextCreator: code formatter used 2017-02-01 17:13:35 +01:00
andsel 1c64186a00 Switched from Moquette's MQTT codec to Netty's MQTT codec ones 2017-01-28 15:59:44 +01:00
andsel 716c9ac0a0 Minor on logging, removed ugly if(isDebugEnabled()) for debug logging, kept only when the toString generation could potentially take long, and trasformed in tracing logs. Moved Error to Warn log level 2017-01-18 23:28:11 +01:00
andsel 60c28f1ecb Minor, just setted autogenerated random serialVersionUID instead of bad 1L 2017-01-18 22:46:04 +01:00
andsel 97ddd1cd8b Merge branch Sofia2 with lot of improvements 2017-01-17 21:40:59 +01:00
Luis Barrios ebdee0bb44 Make netty channel timeout configurable 2017-01-15 14:40:08 +01:00
Luis Barrios d4f977c0af Make several low-level netty parameters configurable 2017-01-13 11:01:35 +01:00
Luis Barrios e7f26e402b Include message and bytes metrics in the status of the active MQTT connections. 2017-01-12 17:25:46 +01:00
Luis Barrios d7d97a74d8 Add simple connection management capabilities to the broker. An external codebase will now be able to monitor and close the opened connections. 2017-01-12 17:00:18 +01:00
Luis Barrios 964efd341e Add log traces 2017-01-12 13:11:08 +01:00
Luis Barrios 03ae299e36 Add log traces 2017-01-12 12:35:51 +01:00
andsel a7b8c07d1a Bumped dev cycle for 0.10 2017-01-11 22:21:03 +01:00
andsel 4162aae3a0 Bumped version 0.9 2017-01-11 22:06:24 +01:00
Luis Barrios 8b3f158a43 Improve logging. Remove duplicated code from QosPublishHandlers. 2017-01-11 18:42:30 +01:00
Luis Barrios aac5b37485 Improve logging 2017-01-11 16:36:45 +01:00
Luis Barrios 953e038223 Improve logging 2017-01-11 16:04:23 +01:00
Luis Barrios 1f1bfff4f7 Improve logging: 
- When a MQTT message is received, we should only log it in debug level. It is better to log the actions performed in the protocol processor at the info level (they are more meaningful).
- Capture and log every exception raised while processing the message (including RuntimeExceptions).
 2017-01-11 15:33:23 +01:00
Luis Barrios 4512eeff23 Add log traces to MoquetteIdleTimeoutHandler and to NettyAcceptor. 
Fix NettyAcceptor shutdown: when the event loops take too long to stop, an IllegalStateException is raised. This leads to leaks, and prevents other
parts of the broker to be shut down properly.
 2017-01-11 15:26:30 +01:00
Luis Barrios e7ba2aee8e Add debug log traces to AutoFlushHandler 2017-01-11 15:06:03 +01:00
Luis Barrios 4ae6893f81 Improve logging of ResourceLoaderConfig 2017-01-11 14:58:35 +01:00
Luis Barrios 1592a0676c Improve logging of package io.moquette.server.config 2017-01-11 14:56:16 +01:00
Luis Barrios 7666a1634a Handle publish errors properly in PersistentQueueMessageSender. Create a connection descriptor store to handle all the message delivery errors and to avoid 
duplicating error handling code (i.e. the connection descriptors map is null, the connection descriptor does not exist, etc).
 2017-01-11 11:23:24 +01:00
Luis Barrios 63d106e414 Improve log traces of the subscriptions store. Make sure that no "raw" RuntimeExceptions are thrown, and include proper log traces before any exception is raised. 2017-01-11 10:42:43 +01:00