Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-19 08:29:02 +00:00
Code Issues Packages Projects Releases Wiki Activity
2,922 Commits 7 Branches 64 Tags
Commit Graph

54 Commits

Author SHA1 Message Date
Martyn Taylor
a79cf3b2da NO-JIRA Cherry-pick fix 2017-02-18 14:04:11 +00:00
Martyn Taylor
7553e4860c NO-JIRA Send MQTT WILL outside of Server Session 
(cherry picked from commit 8b51ec27db2e201c604e8178a574e344d73b033f)
 2017-02-18 13:39:55 +00:00
Martyn Taylor
f082185d7f ARTEMIS-974 ensure will messages are retained 
(cherry picked from commit 5a235d98b63fbbcc94b390252ec8b14ae79a4cda)
 2017-02-16 20:15:12 +00:00
Martyn Taylor
e47b5d6951 NO-JIRA Fix after cherry-pick 2017-02-14 20:28:29 +00:00
Martyn Taylor
b3988647f4 NO-JIRA Clean up around MQTTConnectionManager 
(cherry picked from commit bd1f244dfcd20f7a2c7f22f5a77d40b4e4079230)
 2017-02-14 19:41:50 +00:00
Martyn Taylor
f25396d921 ARTMEIS-958 Route Will message outside server session 
(cherry picked from commit 3bd5c9df6ac28f99e2c3552c8d27fd44eaa0d7a3)
 2017-02-14 19:41:35 +00:00
Martyn Taylor
66c19d9408 ARTEMIS-960 Do not encode Will messages 
(cherry picked from commit 59773c284983f7919c044c54f1a6e2039023701f)
 2017-02-14 19:41:20 +00:00
Martyn Taylor
f231fe4e9b ARTEMIS-917 Only return body of retained message after reboot 
(cherry picked from commit 3900cb0ec7305ee1f341687ace6a4fab7469a817)
 2017-02-10 14:55:24 +00:00
Martyn Taylor
bc8c831722 ARTEMIS-951 Auto Commit MQTT Acks 
(cherry picked from commit cd28d76554b66f618a9fb0352b2e46ecc04f1534)
 2017-02-09 14:11:59 +00:00
Martyn Taylor
3b39dbc34a ARTEMIS-952 Remove MQTT Queues on Clean Session 
(cherry picked from commit b2e250d4254f5d560ddc7fccb4e955e691174fbe)
 2017-02-09 14:11:05 +00:00
Will Reichert
036933a4a4 ARTEMIS-928 Changing Netty and InVM to copy buffers, and retain them on the Netty Polls. 
(cherry picked from commit 3347a4fd2716c7c998a0ef68499f4dc3d8106241)
 2017-01-18 17:04:32 -05:00
Dmitrii Tikhomirov
3995319dca ARTEMIS-865 Remove e.printStackTrace() from code 2016-11-23 11:15:54 -05:00
Clebert Suconic
5e5ac0f057 ARTEMIS-832 Openwire was ignoring data syncs. 
I'm also adding the possibility of sync on libaio, and not only relay on write-cache
 2016-11-02 13:17:12 -05:00
Paul Gallagher
fcb70f3f60 ARTEMIS-779 upgrade to netty 4.1.5.Final 2016-10-10 23:24:56 +02:00
Martyn Taylor
a09348695c ARTEMIS-778 Fix MQTT tests, refactor session state 2016-10-10 23:24:14 +02:00
Clebert Suconic
ec48f9ed00 ARTEMIS-765 Improve Checkstyle 2016-09-30 11:12:09 -04:00
Clebert Suconic
4472aa0e36 ARTEMIS-581 Implement max disk usage, and global-max-size 
max-disk-usage = how much of a disk we can use before the system blocks
global-max-size = how much bytes we can take from memory for messages before we start enter into the configured page mode

This will also change the default created configuration into page-mode as that's more reliable for systems.
 2016-09-06 15:07:49 +01:00
Martyn Taylor
7afd0fb028 ARTEMIS-677 Support websocket subprotocol handshakes 2016-08-10 11:07:47 -04:00
Clebert Suconic
579d6226aa ARTEMIS-671 Returning messages after connection killed, and validating usage of reconnect 2016-08-09 11:23:46 +01:00
bayern39
a741642a48 [ARTEMIS-642] Disable slow client reconnecting with KILL slow client policy 2016-08-03 18:39:57 -04:00
Ville Skyttä
9963f96033 Fix NPE with null session in MQTTConnectionManager.disconnect() 2016-07-28 23:30:02 +03:00
Martyn Taylor
64e95b9b91 This closes #665 2016-07-26 15:14:40 +01:00
Martyn Taylor
69294e83e1 Add management filter to Queue not Consumer MQTT 2016-07-26 12:32:38 +01:00
Ville Skyttä
aed49b3894 Spelling fixes 2016-07-26 14:24:45 +03:00
Martyn Taylor
e341b54c49 ARTEMIS-641 filter out management notifications in MQTT 2016-07-21 14:47:20 -05:00
Martyn Taylor
fe0cb648d6 ARTEMIS-335 Remove dead code from MQTTPublishManager 2016-07-21 14:47:20 -05:00
John D. Ament
7c746c719e ARTEMIS-607 Added interceptor support for MQTT protocol. 
Also updated the maintainer's guide to clarify what is run in the PR builder.
 2016-07-05 19:43:00 -04:00
Ville Skyttä
3923ae45f4 Fix checkstyle redundant modifier violations 2016-06-13 20:03:54 +03:00
Martyn Taylor
e453aae5c9 ARTEMIS-233 Convert TextMessage to UTF8 in MQTT 2016-05-25 15:37:20 -04:00
Martyn Taylor
0d8a565836 Artemis-233 Support JMS BytesMessage -> MQTT 2016-05-25 17:59:00 +01:00
Martyn Taylor
3c7c2ed5d3 ARTEMIS-233 Remove MQTT Address PreFix for cross protocol support 2016-05-25 17:59:00 +01:00
Diego Bes
75a4e78948 Change keep alive ratio to 1.5 from 0.75 
Fixes: ARTEMIS-397

From mqtt specs:

“If the Keep Alive value is non-zero and the Server does not receive a
Control Packet from the Client within one and a half times the Keep
Alive time period, it MUST disconnect the Network Connection to the
Client as if the network had failed [MQTT-3.1.2-24]. “
 2016-05-03 14:14:34 +01:00
Ville Skyttä
3dc3e8520d Remove redundant toString calls 2016-04-11 16:54:30 -04:00
Clebert Suconic
50eac7c824 ARTEMIS-468 Amendments to how redelivery count is handled on openwire 2016-04-07 13:56:31 -04:00
Clebert Suconic
3aedf27386 ARTEMIS-463 More simplifications on the openwire head 
https://issues.apache.org/jira/browse/ARTEMIS-463

This will have some extra refactoring on the protocol head, transferring responsibility to the broker classes in a lot of cases
and removing some duplicated code

This was a team effort from Clebert Suconic and Howard Gao
 2016-04-04 11:08:43 -05:00
Clebert Suconic
6ddf486f8f ARTEMIS-463 Refactoring on Openwire 
https://issues.apache.org/jira/browse/ARTEMIS-463

This was a team effort from Clebert Suconic and Howard Gao
 2016-04-04 11:08:43 -05:00
Clebert Suconic
ee6a03295f ARTEMIS-437 Improving lock over certain protocols 
Avoiding deadlocks between acks and other factors
 2016-03-16 08:23:58 -04:00
Clebert Suconic
9ebc6786b6 ARTEMIS-401 Refactoring Acceptors and ProtocolManager to support parameters 
https://issues.apache.org/jira/browse/ARTEMIS-401
 2016-02-18 10:14:26 -06:00
Clebert Suconic
e62a820414 Fixing ServerMessage's copy and MQTT delivery 2016-01-27 17:12:56 -05:00
Ville Skyttä
d48e344a8f Add missing @Overrides 2015-12-21 22:06:03 -05:00
Clebert Suconic
b1b4bb8a32 ARTEMIS-320 Refactoring TCP flow control and proper implementation of flow control on consumers 
https://issues.apache.org/jira/browse/ARTEMIS-320
 2015-12-10 16:50:26 -05:00
Ville Skyttä
f8a1c5ba8e Remove redundant type arguments 2015-12-07 22:55:05 +02:00
Ville Skyttä
25ae472455 Add missing @Override annotations 2015-12-06 01:27:35 +02:00
Christian Schneider
8cc6c2f5fc More checkstyle fixes 2015-11-24 14:55:35 +01:00
Christian Schneider
be9dad3f2b OSGi support based on branch from gnodet 2015-11-24 11:12:10 +01:00
Clebert Suconic
206acdac7d ARTEMIS-238 and ARTEMIS-236 Fixing Legacy protocol support 2015-10-08 20:32:43 -04:00
Clebert Suconic
5ac2c2444b manual checkstyle changes 2015-08-10 10:08:23 -04:00
Clebert Suconic
bac96047f5 automatic checkstyle change 
this is just calling Idea format on all the files using the new style
I am separating manual changes from automatic changes in case I have to repeat the manual changes again
 2015-08-10 09:26:42 -04:00
Clebert Suconic
6fe9e0ebd6 ARTEMIS-163 First pass on the native AIO refactoring 
https://issues.apache.org/jira/browse/ARTEMIS-163

On this pass I'm just converting the native layer to a simpler one.
It wasn't very easy to change the alignment at the current framework,
so I did some refactoring simplifying the native layer

The volume of the nubmer of changes here is because:

- The API is changed, we now don't close the libaio queue between files
- The native layer won't use malloc as much as it used to, saving some CPU and memory defragmentation
- I organized the code around nio and libaio
 2015-07-29 22:12:03 -04:00
Clebert Suconic
d002da8506 mqtt improvement over retained queue 2015-07-27 10:32:20 -04:00