anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
968 Commits 2 Branches 127 Tags
c48534b0bac07618d583a37531c21b808b108a32
Commit Graph
10 Commits
Author SHA1 Message Date
andsel 1c64186a00 Switched from Moquette's MQTT codec to Netty's MQTT codec ones 2017-01-28 15:59:44 +01:00
Luis Barrios 46fcdc0894 Allow InterceptHandler to specify the messages they can intercept. This allows us to improve the performance of the broker interceptor, and will make log traces more clear. 
- Add methods to return an unique identifier and the supported message types at the InterceptHandler interface.
- Include a default implementation of the new methods in the AbstractInterceptHandler. By default, all the interceptors will be able to handle any message (same as before).
- Comment verifyNoMoreInteractions() call from the BrokerInterceptorTest.testAddAndRemoveInterceptHandler(). The removeInterceptHandler() method of the broker interceptor
  polls the InterceptHandler, so an interaction will always exist after the call to onSubscribe().
 2017-01-10 17:06:13 +01:00
andsel 3f0ab75efb Updated copiright to year 2017 2017-01-04 14:37:29 +01:00
bcw 03c0097641 broker: notify when client connection lost 2016-10-21 10:28:36 +08:00
IODBEEC1 ed9d91e527 add/remove InterceptHandlers with server running 2016-07-09 09:09:57 +02:00
Dee Eldredge 1e7f6d98e7 Based on feedback, renamed messageConsumed -> messageAcknowledged. 2016-03-23 23:11:09 +01:00
Dee Eldredge 7dab8a367f Added username to all messages. From a consumer perspective the username is more useful than a clientID which is often autogenerated. 2016-03-23 23:10:24 +01:00
Dee Eldredge f44283d5f0 Added onMessageConsumed logic. 
Related to:  https://github.com/andsel/moquette/issues/156
 2016-03-23 23:09:16 +01:00
andsel 5487303095 Merged parser_commons into netty_parser 2016-02-03 23:20:15 +01:00
andsel 371c740321 Moved project package from org.eclipse.moquette to io.moquette 2015-11-20 21:30:59 +01:00