heavyrian2012
3b90d145a4
去掉绑定IP地址的配置，防止客户误操作
2022-06-28 08:34:17 +08:00
imhao183
bc25587461
修改端口绑定错误提示
2021-04-12 09:56:08 +08:00
imhao183
3a0653b8ed
添加端口被占用时的提示说明
2021-01-30 09:17:57 +08:00
imhao183
9502b01b49
删除无效的配置及代码
2020-12-24 12:35:07 +08:00
heavyrain2012
d24d71d040
端口被占用时，打印出提醒日志
2020-12-20 15:30:37 +08:00
imhao183
739452830d
用户退出时，多加一种选择，停用session不清除session
2020-04-28 07:40:55 +08:00
heavyrain.lee
d71644c209
添加设置/获取备注api，添加用户在线状态回调功能
2020-01-04 14:47:27 +08:00
heavyrain lee
b2cfc2b99b
add metrics for user channel
2019-07-16 21:56:51 +08:00
heavyrain lee
86e08f6151
Remove useless code
2019-07-16 21:32:55 +08:00
heavyrain.lee
f5a94868c4
remove useless code
2019-07-10 07:30:53 +08:00
imndx
66961b94da
route接口允许跨域访问
2019-06-29 16:42:55 +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
58fd90d33d
Avoid multiple calls to initialize of AutoFlushHadler and extracted common config part MQTT pipeline
2018-11-11 17:27:33 +01:00
andsel
284417ef50
Minor, fixed checkstyle and find bugs warns
2018-11-10 18:31:51 +01:00
andsel
9ceb26307e
Fixed leaks
2018-11-10 17:28:54 +01:00
andsel
11bb0c6fa1
Minor, fixed code style
2018-11-10 14:37:14 +01:00
andsel
dd8bad7480
Minor changes
2018-11-08 22:28:29 +01:00
andsel
e10619813a
Removed all the old ProtocolProcessor stuff
2018-11-08 22:18:11 +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
Ricardo JL Rufino
0f3b3f9ee6
Update MQTTMessageLogger.java
...
reduce the level of logging to less significant things
2018-08-09 23:42:01 -03: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
sbouchex
ce018fe6a0
Fixed NPE while logging an unknown packet (Replaced with an IOException)
2018-06-28 14:13:52 +02:00
Maik Scheibler
d50a291366
enable the usage of Netty OpenSSL provider implementation
...
Signed-off-by: Maik Scheibler <[email protected]
2018-06-22 12:48:06 +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
99f0612209
Minor, fixed logging level to be more usefull for distribution
2018-04-27 15:56:26 +02:00
andsel
513d4d7996
Fixed #339 , sets TCP_NODELAY options on the accepted child socket and not on the accepting
2018-04-27 14:27:58 +02:00
andsel
cf5d619d34
Minor, just improved readability
2018-04-27 13:48:53 +02:00
andsel
033a428184
Fixed checkStyle and ErrorProne warns
2018-04-26 22:23:06 +02:00
Mick
b780b71e5e
Fixed issues #375 , #312
2018-02-09 09:55:29 +01:00
Andreas Mager
8e8a295200
broker/BrokerInterceptor: ByteBuf.retain & release added
...
broker/NettyMQTTHandler: ByteBuf.release added
broker/HazelcastListener: release added
broker/pom: leak detection enabled for surefire tests
broker: ReferenceCountUtil.release used
2017-06-27 16:28:38 +02:00
andsel
ae9c6c7a48
Minor, marked bugsnag ChannelHandler to @Sharable
2017-06-25 12:33:10 +02:00
andsel
3ff3d44d35
Added bugsnag catcher to the pipeline
2017-06-25 11:11:56 +02:00
andsel
ec951738b5
Added BugSnag error tracker
2017-06-20 22:12:42 +02:00
andsel
04a82c4a63
Added num of connected clients and subscription request/sec
2017-06-20 21:55:59 +02:00
andsel
e0104d99f9
Introduced DropwizardMetrics to push data on Librato
2017-06-18 11:04:24 +02:00
andsel
16a9a0ccd0
Fixed runtime loading of persistence implementation
2017-06-18 11:01:25 +02:00
andsel
949e531448
Switched to Netty 4.1.12 to use MqttMessageBuilders
2017-06-10 16:55:00 +02:00
Andreas Mager
fcb7870a38
MemorySessionStore: Session class added
...
MemorySessionStore$Session: clientSession field added
MemorySessionStore#pendingAck: secondPhaseStore & inflightStore &
inboundFlightMeessageToGuid added
ClientSession#cleanup missed these messages
SubscriptionsDirectoryTest: fixed
SessionsStore#dropInFlightMessagesInSession: changed to cleanSession
2017-06-02 18:09:23 +02:00
Andreas Mager
29ef00f24e
broker/NettyAcceptor: epoll added
2017-05-19 16:36:38 +02:00
andsel
2f25863578
Fixed failig message logger
2017-04-30 11:53:15 +02:00
Andreas Mager
0247cfef9e
broker/MQTTMessageLogger: log cases squashed
2017-04-25 16:07:01 +02:00
Andreas Mager
44a7c4d000
broker/MQTTMessageLogger: missing messages added
2017-04-25 16:03:20 +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
Andrea Selva
451b5db941
Merge pull request #280 from fjcyue/master
...
using reader idle to trigger the will message.
2017-03-22 22:20:22 +01:00
andsel
ec6ec09cee
Minor fixed comment ( #281 )
2017-03-19 22:01:23 +01:00
fjcyue
96fb6301a8
using reader idle to trigger the will message.
...
When client power off directly, the socket is broken and server may
still push messages, which just occurred TCP re-transmission at that
time, instead of raising an error immediately. This delayed the will
message.
2017-03-12 01:03:13 +08:00
heavyrian2012