heavyrain2012
cab3ca0916
wildfire chat server source initial submit
2019-03-16 17:04:23 +08:00
andsel
e10619813a
Removed all the old ProtocolProcessor stuff
2018-11-08 22:18:11 +01:00
andsel
ba8ad02289
Dropper Hazelcast because Moquette is not designed to be clusterizable
...
Separated the connect/disconnect logic into ConnectHandler/DisconnectHandler
Moved the sending of CONN ACK after session creation/update
Moved the will message management inside the session class
2018-07-20 18:19:10 +02:00
andsel
34a2aca45e
Minor, updated copyright date
2018-04-27 20:17:47 +02:00
andsel
1b272e5849
Big refactory on session management:
...
- introduced a unique point of access and management of sessions state (SessionRepository)
- separated behaiour for sessions with clean flag to false into DurableSession
- separated behaviour for session with clean flag to true into TransientSession
2017-10-14 17:37:26 +02:00
andsel
53ec8e5b60
Removed the constraint on client queues to be BlockingQueue but simple Queue
2017-06-20 21:55:59 +02:00
andsel
406ffd10db
Merged topic subscription search and publish into single MessagePublisher method
2017-04-29 10:59:34 +02:00
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
6dc762f47f
Introduced the FlightZone concept (inbound and outbound) and separated logic of storage system.
2017-04-09 19:22:50 +02:00
andsel
5c6889fbd5
Separated persistence layer, created submodule for MapDB persistence letting the broker use the in-memory message store
2017-04-01 16:21:34 +02:00
Andreas Mager
91ca7fd1c2
broker/InternalRepublisher: code formatter used
2017-02-01 17:13:39 +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
Luis Barrios
8b3f158a43
Improve logging. Remove duplicated code from QosPublishHandlers.
2017-01-11 18:42:30 +01:00
Luis Barrios
8481fada93
Remove unused imports, raw types and some deprecated method calls..
2017-01-11 10:16:58 +01:00
andsel
081631242f
Removed old 'map based queues' to use persistent BlockingQueues from MapDB
2017-01-09 21:53:26 +01:00
andsel
1831560bd6
Flowed up the creation of messageSender
2016-12-13 23:43:02 +01:00
andsel
f7e8da93d8
Removed data clump
2016-12-13 23:43:02 +01:00
andsel
57586ce7c0
Introduced 2 method, one for retained and not
2016-12-13 23:43:02 +01:00
andsel
633365672c
Changed InternalRepublisher to use the PersistentQueueMessageSender to send out the publish messages
2016-12-13 23:43:02 +01:00
andsel
1c6cbd5d30
Removed the necessity to use BestEffortMessageSender
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
heavyrain2012