anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
1,066 Commits 2 Branches 127 Tags
83dc0f99b6c5dd3a22956c4268a703ea22df36d2
Commit Graph
113 Commits
Author SHA1 Message Date
Andreas Mager 83dc0f99b6 broker/MockAuthenticator: code formatter used 2017-02-01 17:13:43 +01:00
Andreas Mager edc2515caa broker/MemoryStorageService: code formatter used 2017-02-01 17:13:43 +01:00
Andreas Mager be8a2f4ca4 broker/MemoryMessagesStore: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 0bf059afcf broker/BrokerInterceptorTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 47c76fafc1 broker/ClientSessionTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 3ebb9c7d48 broker/ConnectionIT: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager e68c5ce4b0 broker/ConfigurationParserTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 0fc231909c broker/ClasspathResourceLoaderTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager fde2a77aae broker/ServerRestartIntegrationTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 6d4f076969 broker/ServerLowlevelMessagesIntegrationTests: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 6f2796f851 broker/ServerIntegrationWebSocketTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 478ec61cb0 broker/ServerIntegrationSSLTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 667505b13a broker/ServerIntegrationSSLClientAuthTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 4f810fc7fd broker/ServerIntegrationQoSValidationTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager dab5efea30 broker/ServerIntegrationPahoTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 5823bdae46 broker/ServerIntegrationHazelcastHandlerInterceptorTest: code formatter 
used
 2017-02-01 17:13:42 +01:00
Andreas Mager 139db5e5b8 broker/ServerIntegrationFuseTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 4e9e7a8bc1 broker/test/ServerIntegrationEmbeddedPublishTest: code formatter used 2017-02-01 17:13:42 +01:00
Andreas Mager 7b57f04db9 broker/test/ServerIntegrationDBAuthenticatorTest: code formatter used 2017-02-01 17:13:41 +01:00
Andreas Mager 42bd234c76 broker/test/MQTTWebSocket: code formatter used 2017-02-01 17:13:41 +01:00
Andreas Mager 59af0f34ec broker/test/MessageCollector: code formatter used 2017-02-01 17:13:41 +01:00
Andreas Mager 57aaac8a8f broker/test/IntegrationUtils: code formatter used 2017-02-01 17:13:41 +01:00
Andreas Mager dd41de430e broker/test/ConfigurationClassLoaderTest: code formatter used 2017-02-01 17:13:41 +01:00
Andreas Mager ae43010da3 broker/test/Utils: code formatter used 2017-02-01 17:13:41 +01:00
Andrea Selva ff4c5dff3b Merge pull request #261 from AndreasMager/adding-assertj 2017-02-01 13:39:32 +01:00
Andreas Mager 94475d2b04 ProtocolProcessorTest#testCleanRetainedStoreAfterAQoS0AndRetainedTrue: 
check added if test is in the correct state
 2017-01-30 16:07:16 +01:00
Andreas Mager f25af642b0 SubscriptionsStoreTest: containsExactlyInAnyOrder used for matches 2017-01-30 15:51:50 +01:00
Andreas Mager c5b7fd52c5 SubscriptionsStoreTest: assertj used for assertions 2017-01-30 15:51:50 +01:00
Andreas Mager f460d6a230 SubscriptionsStoreTest: classname used for static access 2017-01-30 15:50:42 +01:00
Andreas Mager 504ac3055e SubscriptionsStoreTest: whitespaces removed 2017-01-30 15:50:42 +01:00
andsel 1c64186a00 Switched from Moquette's MQTT codec to Netty's MQTT codec ones 2017-01-28 15:59:44 +01:00
Andreas Mager 01e7465f0c MemorySessionStore: HashMap replaced by Map Interface 2017-01-26 21:42:21 +01:00
Andreas Mager 6f7011c9f2 MemorySessionStore#m_persistentSubscriptions: Map Layout changed 
If one clientid subscribes a lot of topics the old implementation
struggles with the for loops
 2017-01-23 18:37:43 +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 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 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 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 ac2086a0e0 Fixed failing test due to more strict endpoint check from Netty 4.1.x 2016-12-30 00:33:10 +01:00
andsel db7a597bcc Fixed timeout in test 2016-12-28 22:22:27 +01:00
andsel a54b122094 Substituted complex test to check lowering of qos level to the same accepted on subscription time 2016-12-13 23:43:02 +01:00
andsel 296af8b4f6 Renamed route2Subscribers() to publish2Subscribers() 2016-12-13 23:43:01 +01:00
andsel 3355e7c334 Moved selection of subscriptions out of route2Subscribers 2016-12-13 23:43:01 +01:00
andsel b6239b3c5c Changed SUBSCRIPTION processing to be based on concurrent FSM 2016-11-27 21:35:20 +01:00
andsel 38746ad0dd Moved existing CONNECT processing to an FSM 2016-11-27 21:35:20 +01:00
andsel 7508275cf7 Changed the way a Client session is active and moved to event and states of Channel for CONNECT and DISCONNET messages 2016-11-05 18:29:08 +01:00