anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
1,009 Commits 2 Branches 127 Tags
12b2819e45913b6ba13bf9780b07d5654493f38f
Commit Graph
1009 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
Luis Barrios e7ba2aee8e Add debug log traces to AutoFlushHandler 2017-01-11 15:06:03 +01:00
Luis Barrios 4ae6893f81 Improve logging of ResourceLoaderConfig 2017-01-11 14:58:35 +01:00
Luis Barrios 1592a0676c Improve logging of package io.moquette.server.config 2017-01-11 14:56:16 +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
Luis Barrios 63d106e414 Improve log traces of the subscriptions store. Make sure that no "raw" RuntimeExceptions are thrown, and include proper log traces before any exception is raised. 2017-01-11 10:42:43 +01:00
Luis Barrios 8481fada93 Remove unused imports, raw types and some deprecated method calls.. 2017-01-11 10:16:58 +01:00
Luis Barrios 933763486c Remove rawtypes 2017-01-11 09:05:30 +01:00
Luis Barrios c90893d817 Add missing method implementation 2017-01-10 17:29:37 +01:00
Luis Barrios aea4f3709a Make the size of the BrokerInterceptor thread pool configurable. 2017-01-10 17:23:15 +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
Luis Barrios 1d75a25aa3 Update .gitignore file to exclude /osgi_test/target/ and /perf/target/ 2017-01-10 14:31:17 +01:00
Luis Barrios 0786de54b2 Update .gitignore file to exclude /osgi_test/target/ and /perf/target/ 2017-01-10 12:39:46 +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
andsel 480e36579c Fixed NPE exception of inflight ACK because the publisher with clean=true removed all messages, also the published from message store 2017-01-04 11:17:30 +01:00
andsel 2c43c74fe3 Added gracefull handling when client cut TCP connection 2017-01-04 11:13:58 +01:00
andsel 4029ddd2b1 Removed ClasspathConfig to use the ClasspathResourceLoader and basic ResourceLoaderConfig 
Removed FilesystemConfig to use the FileResourceLoader and basic ResourceLoaderConfig
 2016-12-31 19:30:41 +01:00
andsel 0f41c9ea08 Changed default behaviour to use persistent sotre, now use in memory as default and not FS moquette.mapdb (Fix issue #242) 2016-12-31 16:06:18 +01:00
andsel a146ffb30e Minor changes to distribution's log4j config file to include the messagelog logger 2016-12-31 15:28:06 +01:00
Neeme Praks ac93f04dde Refactored config file resource loading to make it easier to load config files from class path when embedding. 2016-12-31 11:46:32 +01:00
Andrea Selva c36ebc648b Minor, removed test lib deps in OSGi test module 2016-12-30 10:04:15 +01:00
andsel dd61be59b3 Switched from http encoder and decoder to codec, and fixed logger to check message type before log 2016-12-30 00:33:10 +01:00
andsel ac2086a0e0 Fixed failing test due to more strict endpoint check from Netty 4.1.x 2016-12-30 00:33:10 +01:00
Andrea Selva ea043bc743 Merge pull request #246 from nemecec/fix-deps 
Remove compile-time dependency on log4j
 2016-12-29 14:59:38 +01:00
Andrea Selva 3dce95cc50 Merge pull request #245 from nemecec/patch-1 
MessageDigest is not thread-safe
 2016-12-29 14:59:19 +01:00
andsel 1ad5f4aef9 Added MQTT message logger 2016-12-28 22:22:55 +01:00
andsel db7a597bcc Fixed timeout in test 2016-12-28 22:22:27 +01:00
andsel d3116dc685 Fixed inactive channel propagation event through MQTTMessageLogger 2016-12-28 22:21:33 +01:00
Neeme Praks 9bf909b4db Move log4j dependency from broker to dist - otherwise it is propagated transitively to projects using moquette as a library. Also removed redundant logback-core dependency from OSGi tests (it already has logback-classic). 2016-12-28 00:45:56 +02:00
Neeme Praks be42cfaae1 MessageDigest is not thread-safe 
MessageDigest is not thread-safe. Use DigestUtils instead, it is also more convenient (and Moquette already has a dependency on commons-codec).
 2016-12-28 00:36:01 +02:00
andsel 4e2a0dbf28 Switched to netty 4.1.6 to include Netty's official mqtt codec to make some performance tests 2016-12-27 22:28:34 +01:00
andsel 8aa683452a Added performance project module, to stress test specifics part of Moquette 2016-12-26 12:25:54 +01:00
andsel 642fa4a4aa Added plain publish bomber test, to measure enoding/deconding perf 2016-12-26 12:13:30 +01:00
andsel 686c5f4c65 Embedded pub and sub client into same process of the plain test broker to use same nanosecs 2016-12-24 15:36:20 +01:00
andsel 43f56a8f39 Removed unused methods 2016-12-24 14:42:40 +01:00
andsel 68a4093e1a Subscriber for benchmarking using Paho API 2016-12-21 23:17:22 +01:00
andsel 631049877e Implemented Publisher with Paho API 2016-12-21 22:37:53 +01:00
andsel 7b97855a3b Moved fuse benchmark into separate dir 2016-12-21 21:48:53 +01:00
andsel 08b5cd8333 Minor, just comment 2016-12-18 19:51:40 +01:00
andsel e812efd6b7 Added MQTT messages logger 2016-12-18 19:51:40 +01:00
Andrea Selva dfd985da95 Fixed sha, before was the sha256("passwd\n") 2016-12-14 18:08:31 +01:00
andsel 1831560bd6 Flowed up the creation of messageSender 2016-12-13 23:43:02 +01:00
andsel f7e8da93d8 Removed data clump 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 012e0687a8 Removed unused class BestEffortMessageSender 2016-12-13 23:43:02 +01:00
andsel 1c6cbd5d30 Removed the necessity to use BestEffortMessageSender 2016-12-13 23:43:02 +01:00