heavyrain.lee
c1b9a81e12
重构黑名单,修改代码
2019-11-18 14:53:20 +08:00
heavyrain.lee
a6fd11a243
修复部分接口
2019-08-08 08:28:00 +08:00
heavyrain.lee
5fee857c4a
add system settings
2019-07-30 07:54:49 +08:00
heavyrain.lee
031e96075e
群组权限
2019-07-08 23:08:04 +08:00
heavyrain lee
9365807f47
群组踢人错误修改
2019-07-05 08:19:29 +08:00
heavyrain lee
25ce10fa61
删除好友通知
2019-07-04 10:19:07 +08:00
heavyrain.lee
5bb8ab3d95
update
2019-06-29 12:01:46 +08:00
heavyrain.lee
8dfc23b61d
update code
2019-06-29 12:01:37 +08:00
heavyrain.lee
a149139143
添加敏感词命中消息表t_sensitive_messages
2019-06-12 22:57:30 +08:00
heavyrain.lee
ea301a3923
修改内部接口定义
2019-06-09 07:37:33 +08:00
heavyrain.lee
d0671c1682
add broad cast message
2019-05-31 07:56:31 +08:00
heavyrain.lee
331c38cc98
update
2019-05-25 07:55:30 +08:00
heavyrain.lee
fbd1a7f5dc
update
2019-05-24 21:08:31 +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
640a4fa47c
用户关系的api
2019-05-20 19:51:57 +08:00
heavyrain.lee
ab3882e1d4
friend alias
2019-05-02 21:43:01 +08:00
heavyrain lee
0f05d63a3b
Add load history message function
2019-04-19 08:15:27 +08:00
heavyrain2012
8ef92d0c1b
fix modify group notification timestamp issue
2019-04-04 07:39:41 +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
cfa478067e
Removed unused persistence classes
2018-11-14 22:13:42 +01: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
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
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
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
406ffd10db
Merged topic subscription search and publish into single MessagePublisher method
2017-04-29 10:59:34 +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
Andreas Mager
63d2f2dd69
broker/MapDBPersistentStore: Interfaces used for the Constructors
...
broker/IStore: Interface added for MapDBPersistentStore
broker/ProtocolProcessorBootstrapper: class loader for store added
broker/ISessionsStore#mapToGuid: moved to IMessagesStore
broker/ProtocolProcessorBootstrapper: getter used for SessionStore
broker/Server: getter for processor added
broker/ProtocolProcessor: getter added for Stores
2017-03-20 13:04:14 +01:00
andsel
ec6ec09cee
Minor fixed comment ( #281 )
2017-03-19 22:01:23 +01:00
Andreas Mager
a2e51b2c31
broker/Topic: class added
...
broker/Topic: String Topics replaced by Topic class
broker/Topic#parseTopic: access set to private
broker/SubscriptionsStoreTest: topic tests moved to own class
broker/TopicTest: containsExactly used
broker/TopicTest: TopicAssert class added
broker/TopicTest$TopicAssert#containsToken: method added
broker/TopicTest$TopicAssert#matches: method added
2017-02-19 18:29:37 +01:00
Andreas Mager
d2d77eb608
broker/IMessagesStore: 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
60c28f1ecb
Minor, just setted autogenerated random serialVersionUID instead of bad 1L
2017-01-18 22:46:04 +01:00
Luis Barrios
d7d97a74d8
Add simple connection management capabilities to the broker. An external codebase will now be able to monitor and close the opened connections.
2017-01-12 17:00:18 +01:00
Luis Barrios
8481fada93
Remove unused imports, raw types and some deprecated method calls..
2017-01-11 10:16:58 +01:00
andsel
ac8a11fefa
Removed the reference counter for stored messages
2017-01-09 21:59:09 +01:00
andsel
081631242f
Removed old 'map based queues' to use persistent BlockingQueues from MapDB
2017-01-09 21:53:26 +01:00
andsel
3f0ab75efb
Updated copiright to year 2017
2017-01-04 14:37:29 +01:00
andsel
12a3c65c9b
Fixed javadoc (issue #164 )
2017-01-04 12:52:42 +01:00
chris-lumigrow
2bc5df8703
implement #227 , use of atomicintegers on reference counter
2016-11-10 14:13:42 -08:00
andsel
8215e89d77
Changed String for guids to its value object
2016-09-23 11:51:25 +02:00
andsel
4d637a349b
Fixed drop messages in clean session phase, introduced ref counter
2016-09-23 09:45:47 +02:00
andsel
5487303095
Merged parser_commons into netty_parser
2016-02-03 23:20:15 +01:00
andsel
4c1f36cf67
MOved the method nextClientID from IMessagesStore to the ISessionsStore because it's session related
2016-01-17 13:00:36 +01:00
andsel
5f83465529
Removed a queue per client of inFlightIds (never cleaned) in favor of single atomic generator, fixes issue #130
2016-01-02 16:43:12 +01:00
andsel
371c740321
Moved project package from org.eclipse.moquette to io.moquette
2015-11-20 21:30:59 +01:00