imhao183
0c0d712869
update
2019-12-30 16:00:14 +08:00
imhao183
11375133ba
禁止发送消息给被封禁用户
2019-12-26 21:18:34 +08:00
imhao183
583df110fd
Revert "Fix potential GZIPOutputStream resource leak on exception"
...
This reverts commit 6c7d2ab3ad
2019-12-13 12:57:59 +08:00
gitlab-runner
6c7d2ab3ad
Fix potential GZIPOutputStream resource leak on exception
2019-11-30 23:05:28 +08:00
heavyrain2012
f9d5c861ce
优化用户session
2019-11-27 10:30:39 +08:00
heavyrain2012
33637229d6
限制多端登陆
2019-11-25 11:19:53 +08:00
heavyrain2012
b3a95c0310
update
2019-11-21 10:24:16 +08:00
heavyrain.lee
c1b9a81e12
重构黑名单，修改代码
2019-11-18 14:53:20 +08:00
heavyrain lee
38b84f0fa5
解决封禁用户无法踢用户下线的问题
2019-07-21 12:18:38 +08:00
heavyrain.lee
5ef8868916
接受新消息通知错误
2019-06-19 14:18:09 +08:00
heavyrain.lee
b4b70ca7e5
增加协议版本，新版本添加对gzip的支持
2019-05-27 10:06:22 +08:00
heavyrain.lee
d3aa68df05
fix error
2019-05-26 23:46:42 +08:00
heavyrain.lee
36aa0518ed
add gzip
2019-05-25 22:56:11 +08:00
heavyrain.lee
b1c5692322
fix some error
2019-05-25 22:53:10 +08:00
heavyrain.lee
af4d73a0d5
推送提示错误
2019-05-25 07:55:58 +08:00
heavyrain.lee
675025c0ec
解决session在重启后，内存中不存在的问题
2019-05-24 16:33:35 +08:00
heavyrain.lee
d36c3f4f77
update
2019-05-22 20:24:21 +08:00
heavyrain.lee
79bd0c3304
add sdk
2019-05-22 08:38:55 +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
cf619ebeee
Add admin flag for all handler
2019-04-26 08:06:02 +08:00
heavyrain lee
9fdc6c2e1b
Add admin flag
2019-04-26 08:02:14 +08:00
heavyrain lee
90c8e49808
服务重启后，用户登录时加载用户session
2019-04-25 08:15:28 +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
1ba9eb3613
Moved packages from old io.moquette.server to new io.moquette.broker
2018-11-11 18:06:13 +01:00
andsel
284417ef50
Minor, fixed checkstyle and find bugs warns
2018-11-10 18:31:51 +01:00
andsel
e10619813a
Removed all the old ProtocolProcessor stuff
2018-11-08 22:18:11 +01:00
andsel
176b986c47
Introduced interceptors notification into new broker
2018-11-02 16:49:50 +01:00
andsel
a2266e5bbe
Rearchitected the broker, switching from ProtocolProcessor and publisher to MQTTConnection, Session and PostOffice
2018-11-02 12:33:59 +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
8a03dd8131
Fixed issue #415 by adding a configuration flag to force subscription re-authentication on client connect
2018-07-19 17:23:18 +02:00
andsel
5e4c70edce
Fixed issue #412 adding a check on Topic's string length in processPublish
2018-06-28 23:26:56 +02:00
andsel
88e0ccf20e
On retained republish message adapt the QoS to the one specified during subscription (fix issue #411 )
2018-06-28 00:26:42 +02:00
andsel
ea0ad14374
Fixed issue #410 reserved flag set in unsubscribe
2018-06-26 15:00:36 +02:00
andsel
3c9cc5fa8e
Fixed issue #380 , now catch and print the full stack trace on error
2018-05-07 20:26:40 +02: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
99f0612209
Minor, fixed logging level to be more usefull for distribution
2018-04-27 15:56:26 +02:00
andsel
fc59b51558
Fix #381 , avoid t print password on bad signin during connect
2018-04-27 13:08:12 +02:00
andsel
5456431dd4
Fixed bug #400 a transient session (clean=true) that tried to lookup session from persistent store
2018-04-27 12:44:48 +02:00
andsel
033a428184
Fixed checkStyle and ErrorProne warns
2018-04-26 22:23:06 +02:00
Marcus Williford
1bc6bdbbce
Fix for CTrie TNode exception and other improvements to CTrie related
...
subscribe and unsubscribe issues
- Added unit tests to cover a few more cases which I my system ran into
under concurrent load testing.
- Remove and detect TNode, implement more of
http://bravenewgeek.com/breaking-and-entering-lose-the-lock-while-embracing-concurrency/
related to TNode state
- NOTE: The graph is left with nodes which have no subscriptions, the
TNode cleanup only cleanss the last node for now. We should
autoprune further up by placing more TNodes and pruning them off.
- Adding concurrency Sets and Lists to CNode, because those ARE edited
and read in parallel in our use-case. Before a CNode is CAS
replaced, more than 1 thread may be attempting to modify and read the
subscriptions and children CNode datastructures, and I hit this
during testing.
- Fixed an issue where we unsubscribe all sub-topics if an unsubscribe
is sent on a parent node.
- Fixed an issue with unsubscribing multiple times when no subscrition
exists, we should handle this gracefully.
2017-10-24 09:45:12 -07:00
andsel
3293478dd7
Fixed issue #362
2017-10-20 12:27:50 +02:00
andsel
ba2b8b44d3
Fixed issue #360 , used a DB connection pool instead of long lasting Drivers connections
2017-10-20 12:25:10 +02:00
andsel
f7b213a677
Added tracking of closed session time and expired session cleaner for clients that never reconnects but had clean session flag = false
2017-10-20 11:48:34 +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
Andrea Selva
ed87abaaaa
Merge pull request #340 from nMoncho/ACL_COMMENTS
...
#310 - Allow for topic/patterns with '#' and end of line comments
2017-08-23 10:02:29 +02:00
Gustavo De Micheli
89174178c6
#310 - Allow for topic/patterns with '#' and end of line comments
2017-08-23 09:43:51 +02:00
imhao183