imhao183
b66aa3d634
消息转发时带上消息ID和时间戳
2020-06-04 07:44:11 +08:00
imhao183
d099c2aa14
好友请求推送
2020-03-26 13:31:35 +08:00
heavyrain.lee
5187e63329
透传消息如果是超过一小时不在线就不需要发送了
2020-03-06 08:11:42 +08:00
heavyrain.lee
a1b4eca6f2
修改推送时名称的问题
2020-02-21 11:19:52 +08:00
heavyrain.lee
2e4cf566c7
add exception log
2020-01-10 12:34:31 +08:00
heavyrain.lee
7c4fe831b3
优化聊天室逻辑，添加聊天室空闲退出时间和发消息重新加入配置
2020-01-05 12:36:36 +08:00
heavyrain.lee
5ef8868916
接受新消息通知错误
2019-06-19 14:18:09 +08:00
heavyrain.lee
af4d73a0d5
推送提示错误
2019-05-25 07:55:58 +08:00
heavyrain.lee
77a5d61861
调整代码目录结构
2019-05-22 07:23:09 +08:00
heavyrain lee
b47084f61f
Fix error
2019-05-01 08:13:40 +08:00
heavyrain.lee
9560b9c202
1, 修改本地运行时version检查错误。2，修改好友被删除后再次添加好友。3，优化部分流程
2019-04-12 14:37:52 +08:00
heavyrain2012
0f15a3840e
优化部分逻辑
2019-04-02 22:55:29 +08:00
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
34a2aca45e
Minor, updated copyright date
2018-04-27 20:17:47 +02:00
andsel
6bbeba1612
Moved avay from ConnectionDescriptorStore unused methods and stuff that hasn't nothing about ConnectionDescriptor storing
2018-04-27 20:16:11 +02:00
andsel
033a428184
Fixed checkStyle and ErrorProne warns
2018-04-26 22:23:06 +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
d7023ae81b
Extracted common subscriptions directory interface and switched to CTrie inspired implementation
2017-07-29 17:10:01 +02:00
andsel
d9ff81131c
Merged topic subscription search and publish into single MessagePublisher method
...
First step on implementing H2 storage
Minor, fixed not imported class
Cleaned MessageStore interface to avoid duplication of methods used in couple. Switched from guid + message to move messages
Separated ISubscriptionsStore from ISessionStore
Implemented H2 queue
2017-06-02 10:13:34 +02:00
andsel
85a787993c
Added missing persist on QoS1 retained publish
2017-04-30 11:31:05 +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
a308780acd
broker/MessagesPublisher: 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
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
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
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
32244e9482
Peeled common code
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
3100d835df
Moved params out of publishQos0
2016-12-13 23:43:02 +01:00
andsel
da94a6a014
Moved params out of publishQos2
2016-12-13 23:43:02 +01:00
andsel
57d9eeef64
Just renames
2016-12-13 23:43:02 +01:00
imhao183