Andreas Mager
9221a87812
editorconfig: max line length set
...
max line length warnings removed
missing Copyright added
useless publics removed
unmaintainable Javadoc tags: @author removed
helper class warnings removed
field default value initialization removed
Multiple warnings removed
pref: checkstyle warnings removed
Checkstyle will fail the build process if it detects violations
switch default cases error logger added
2017-04-13 22:16:57 +02:00
andsel
ec6ec09cee
Minor fixed comment ( #281 )
2017-03-19 22:01:23 +01:00
Andreas Mager
725220a99b
broker/ConnectionDescriptor: code formatter used
2017-02-01 17:25:08 +01:00
Andreas Mager
5c9d0808dd
broker/ConnectionDescriptor: code formatter used
2017-02-01 17:13:37 +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
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
andsel
3f0ab75efb
Updated copiright to year 2017
2017-01-04 14:37:29 +01:00
andsel
b6239b3c5c
Changed SUBSCRIPTION processing to be based on concurrent FSM
2016-11-27 21:35:20 +01:00
andsel
18fa8f4baf
Reworked DISCONNECT to be implemented as 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
8e43f75f70
Minor changes
2016-11-05 18:29:08 +01:00
andsel
43f7223a15
Minor refactory, renamed var names from session to 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
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
andsel
371c740321
Moved project package from org.eclipse.moquette to io.moquette
2015-11-20 21:30:59 +01:00
Andreas Mager