anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
898 Commits 2 Branches 127 Tags
4162aae3a0a4e697e49983858afacb2fe1f60af5
Commit Graph
100 Commits
This Branch
This Branch
All Branches
Author SHA1 Message Date
andsel 4162aae3a0 Bumped version 0.9 2017-01-11 22:06:24 +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
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
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
andsel 3100d835df Moved params out of publishQos0 2016-12-13 23:43:02 +01:00
andsel da94a6a014 Moved params out of publishQos2 2016-12-13 23:43:02 +01:00
andsel 2640a5354c Minor, unified method 2016-12-13 23:43:02 +01:00
andsel 57d9eeef64 Just renames 2016-12-13 23:43:02 +01:00
andsel 0bfdc88e21 Removed unused argument 2016-12-13 23:43:02 +01:00
andsel 0e0afe7c9b Renames 2016-12-13 23:43:02 +01:00
andsel c76db85ae7 Removed unused params 2016-12-13 23:43:02 +01:00
andsel 2b554ca475 Condensed the looping on subscription on separate class 2016-12-13 23:43:02 +01:00
andsel b58cd086ea Inverted some ifs to get the semantic of ifs more clear 2016-12-13 23:43:02 +01:00
andsel 968e021711 Reintroduced bad removed conditions 2016-12-13 23:43:02 +01:00
andsel 105a06537c Moved code to make InternalPublisher.publishRetained() almost similar to InternalPublisher.publishStored() 2016-12-13 23:43:02 +01:00
andsel 5d02239dc1 Extracted common code for internal republish 2016-12-13 23:43:02 +01:00
andsel 5b254cfe75 Changed che willpublish to use the Qos2Publisher helper class 2016-12-13 23:43:02 +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 1e04292ba2 Moved qos2 publish to separate class 2016-12-13 23:43:02 +01:00
andsel 1c2fe8c8fe Moved publishing logic for qos1 to separate class 2016-12-13 23:43:02 +01:00
andsel a53772f094 Separated qos0 publishing logic from publish handler 2016-12-13 23:43:02 +01:00
andsel e6bb883334 Minor, just public class to package private 2016-12-13 23:43:02 +01:00
andsel a9f53a4a95 Moved Qos2 publish handling code to separate class 2016-12-13 23:43:02 +01:00
andsel d65886343b Moved QoS1 publish handling to separate class 2016-12-13 23:43:02 +01:00
andsel 81a447dce9 Reinserted route to qo0 branch in publish2Subscribers for internal publish 2016-12-13 23:43:02 +01:00
andsel 12ed805737 Moved qos0 publishing logic to separate class 2016-12-13 23:43:01 +01:00
andsel c62f549176 Minor, just code layout 2016-12-13 23:43:01 +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 c727ee87d3 Extracted method to verify credentials on publish 2016-12-13 23:43:01 +01:00
andsel c28673b83b introduced methods to threat every single qos 2016-12-13 23:43:01 +01:00
Andrea Selva 5ca48ddd73 Merge pull request #240 from kmhughes/master 
Make Moquette into OSGi bundles.
 2016-12-12 22:00:01 +01:00
andsel 558b4a4c64 Changed SUBSCRIPTION processing to be based on concurrent FSM 2016-12-08 16:31:01 +01:00
andsel b6239b3c5c Changed SUBSCRIPTION processing to be based on concurrent FSM 2016-11-27 21:35:20 +01:00
andsel 3ac692a7c7 Removed unuseful sessionStolen attribute from channel 2016-11-27 21:35:20 +01:00
andsel 9a7e643742 Cleaned unused code 2016-11-27 21:35:20 +01:00
andsel 18fa8f4baf Reworked DISCONNECT to be implemented as 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
Andrea Selva 40de41adc8 Merge pull request #231 from windbender/master 
implement #227, use of atomicintegers on reference counter
 2016-11-11 13:49: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
andsel 8e43f75f70 Minor changes 2016-11-05 18:29:08 +01:00
andsel b51b3214ba Added FSM documentation 2016-11-05 18:29:08 +01:00
andsel b7dec8f65e Minor change, just log in disconnet decoder 2016-11-05 18:29:08 +01:00
Andrea Selva ccdb50e760 Merge pull request #224 from bcw104/master 
broker: notify when client connection lost
 2016-11-05 17:08:09 +01:00
Andrea Selva e136caef91 Merge pull request #225 from mpaatz/master 
fixed ConcurrentModification Exceptions in MapDBSessionsStore, fixes #215
 2016-10-26 13:52:31 +02:00
Andrea Selva 502deb840b Merge pull request #212 from teranisi/get_subscriptions_api 
Add 'getSubscriptions' API on Server.
 2016-10-26 13:46:30 +02:00
andsel cf67d5ac52 Fixed the issue 204, forcing flush at each write insted of wait for the Channel to be flushed 2016-09-27 22:35:16 +02:00
andsel 912a88ec0a Minor, switched from .replace to .put (JDK 1.7 compatibility) 2016-09-23 12:10:42 +02:00
andsel 8215e89d77 Changed String for guids to its value object 2016-09-23 11:51:25 +02:00
andsel ac419adbd6 Drop the message when the ref counter reaches 0 2016-09-23 10:16:24 +02:00
andsel ac5a4daa6f Changed the way of create MapDB's messages and session stores, it's now more coupled (they are the same stuff at the end) 2016-09-23 10:11:50 +02:00
andsel 4d637a349b Fixed drop messages in clean session phase, introduced ref counter 2016-09-23 09:45:47 +02:00
andsel 5efad350d8 Fixed the configuration of HZ for local tests to avoid multicast preferring tcp local address 2016-09-12 17:49:40 +02:00
andsel 4790325f0e Added MapDP perf test groovy script 2016-09-12 12:39:43 +02:00
andsel 181303b58b Merge branch 'master' of github.com:andsel/moquette 2016-09-12 12:29:01 +02:00
andsel 55ea2d7c12 Added lab experiment to check H2 MVStore perf 2016-09-12 12:28:55 +02:00
Andrea Selva 40f2d87434 Merge pull request #202 from FraunhoferIOSB/Bugfix-PersistenceFileLock 
Bugfix for ServerRestartIntegrationTest - Persistence file could not be deleted under Windows
 2016-08-19 09:00:57 +02:00
Andrea Selva 8b7458a6c4 Merge pull request #191 from kevto/hotfix/allow-zero-byte-clientid 
Allow zero byte client identifiers in the connect message.
 2016-08-07 22:29:56 +02:00
Andrea Selva 3c614910e5 Merge pull request #192 from kevto/hotfix/anonymous-invalid-close-connection 
Closing connection on non-zero return code in CONNACK packet.
 2016-08-07 22:15:33 +02:00
andsel 32b6b9b1da Minor, renamed SimpleMessaging to ProtocolProcessorBootstrapper 2016-07-22 13:32:25 +02:00
andsel 8cc588d766 Simplyfied creation of HazelcastMsg from InterceptPublishMessage 2016-07-22 13:19:16 +02:00
andsel 29fd6d03b9 Minor refact in HZ configuration 2016-07-22 13:08:48 +02:00
andsel 81100e13b4 Switched to HZ 3.5.4 2016-07-22 12:43:12 +02:00
Andrea Selva 3085ee54d8 Merge pull request #189 from andsel/mackristof-feat/cluster 
Mackristof feat/cluster
 2016-07-22 12:13:16 +02:00
andsel fedd2965cc Fixed Hazelcast itnegration tests, removing unusefull thread sleeps, but more important permitting the co existence of 2 Brokers in the same JVM 2016-07-22 12:09:10 +02:00
andsel 7886bf7103 Merge branch 'feat/cluster' of https://github.com/mackristof/moquette into mackristof-feat/cluster 2016-07-21 16:17:15 +02:00
Andrea Selva 6a4aa28489 Merge pull request #188 from kevto/hotfix/client-session-subscribe 
One param less in ClientSession subscribe method
 2016-07-18 21:40:09 +02:00
Andrea Selva 3d2e69cc21 Merge pull request #187 from iodb/master 
add/remove InterceptHandlers with server running
 2016-07-10 11:22:44 +02:00
andsel 1ef2a4fd3c Minor change, remove a redundant ClientID param from verifyToActivate method 2016-07-02 12:30:19 +02:00