 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 |
|