 andsel
|
da94a6a014
|
Moved params out of publishQos2
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
2640a5354c
|
Minor, unified method
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
57d9eeef64
|
Just renames
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
0bfdc88e21
|
Removed unused argument
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
0e0afe7c9b
|
Renames
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
c76db85ae7
|
Removed unused params
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
2b554ca475
|
Condensed the looping on subscription on separate class
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
b58cd086ea
|
Inverted some ifs to get the semantic of ifs more clear
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
968e021711
|
Reintroduced bad removed conditions
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
105a06537c
|
Moved code to make InternalPublisher.publishRetained() almost similar to InternalPublisher.publishStored()
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
5d02239dc1
|
Extracted common code for internal republish
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
5b254cfe75
|
Changed che willpublish to use the Qos2Publisher helper class
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
1e04292ba2
|
Moved qos2 publish to separate class
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
1c2fe8c8fe
|
Moved publishing logic for qos1 to separate class
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
a53772f094
|
Separated qos0 publishing logic from publish handler
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
e6bb883334
|
Minor, just public class to package private
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
a9f53a4a95
|
Moved Qos2 publish handling code to separate class
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
d65886343b
|
Moved QoS1 publish handling to separate class
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
81a447dce9
|
Reinserted route to qo0 branch in publish2Subscribers for internal publish
|
2016-12-13 23:43:02 +01:00 |
|
|
andsel
|
12ed805737
|
Moved qos0 publishing logic to separate class
|
2016-12-13 23:43:01 +01:00 |
|
|
andsel
|
c62f549176
|
Minor, just code layout
|
2016-12-13 23:43:01 +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
|
c727ee87d3
|
Extracted method to verify credentials on publish
|
2016-12-13 23:43:01 +01:00 |
|
|
andsel
|
c28673b83b
|
introduced methods to threat every single qos
|
2016-12-13 23:43:01 +01:00 |
|
|
andsel
|
558b4a4c64
|
Changed SUBSCRIPTION processing to be based on concurrent FSM
|
2016-12-08 16:31:01 +01:00 |
|
|
andsel
|
b6239b3c5c
|
Changed SUBSCRIPTION processing to be based on concurrent FSM
|
2016-11-27 21:35:20 +01:00 |
|
|
andsel
|
3ac692a7c7
|
Removed unuseful sessionStolen attribute from channel
|
2016-11-27 21:35:20 +01:00 |
|
|
andsel
|
9a7e643742
|
Cleaned unused code
|
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 |
|
|
chris-lumigrow
|
9c62e3d05c
|
a bit of defensive programming in the case of negative reference values
|
2016-11-10 14:19:43 -08:00 |
|
|
chris-lumigrow
|
2bc5df8703
|
implement #227, use of atomicintegers on reference counter
|
2016-11-10 14:13:42 -08: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 |
|
|
andsel
|
8e43f75f70
|
Minor changes
|
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 |
|
|
Andrea Selva
|
e136caef91
|
Merge pull request #225 from mpaatz/master
fixed ConcurrentModification Exceptions in MapDBSessionsStore, fixes #215
|
2016-10-26 13:52:31 +02:00 |
|
|
bcw
|
3e89bc5d2c
|
notify when client connection lost；
implement onConnectionLost() method in AbstractInterceptHandler.java;
|
2016-10-24 11:37:10 +08:00 |
|
|
mpaatz
|
b1850e1dfe
|
Fixed ConcurrentModification Exceptions in MapDBSessionsStore, fixes #215
|
2016-10-21 15:23:30 +02:00 |
|
|
bcw
|
03c0097641
|
broker: notify when client connection lost
|
2016-10-21 10:28:36 +08:00 |
|
|
teranisi
|
0c5f0f293f
|
Merge conflicts.
|
2016-10-20 14:27:51 +09:00 |
|
|
teranisi
|
90998c447b
|
Make Subscription class immutable.
|
2016-10-20 14:23:57 +09: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
|
cf67d5ac52
|
Fixed the issue 204, forcing flush at each write insted of wait for the Channel to be flushed
|
2016-09-27 22:35:16 +02: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
|
ac419adbd6
|
Drop the message when the ref counter reaches 0
|
2016-09-23 10:16:24 +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 |
|
|
teranisi
|
d664227436
|
Add 'getSubscriptions' API on Server.
Add a test for sessions without clean session flag.
|
2016-09-16 22:52:35 +09:00 |
|