Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-07 18:49:14 +00:00
Code Issues Packages Projects Releases Wiki Activity
8,689 Commits 6 Branches 64 Tags
Commit Graph

129 Commits

Author SHA1 Message Date
Justin Bertram
a965b6d2ee ARTEMIS-1358 refactor MQTTProtocolManager a bit 2017-08-22 22:08:24 -04:00
Otavio R. Piske
654ea69e78 Implement support for intercepting additional MQTT control packets 
Previously, only the PUBLISH packet was intercepted. This patch modifies
the code to add support for the other incoming/outgoing MQTT control
packets.
 2017-08-17 10:11:21 -05:00
Martyn Taylor
bb3965b7f7 ARTEMIS-1349 Add management views for client objects 2017-08-17 10:44:41 +01:00
Michael Andre Pearce
62e1f7b1e1 ARTEMIS-1335 Update Netty to 4.1.14 - MQTT fix 
Fix for MQTT in connect due to deprecated methods bug causing NPE, call new methods and null check ourselves.

Also raised https://github.com/netty/netty/issues/7076 upstream but i guess we will keep this, as the old methods are deprecated anyhow.
 2017-08-10 01:52:50 +01:00
gtully
ca7197b5c3 [ARTEMIS-1310] add amqp sasl gssapi mechanism support 
delegate to the jdk saslServer. Allow acceptor configuration of supported mechanismis; saslMechanisms=<a,b>
and allow login config scope for krb5 to be configured via saslLoginConfigScope=x
 2017-08-08 13:28:50 -04:00
Odyldzhon Toshbekov
34697d58e1 ARTEMIS-1272 fix mqtt acknowledgement issue 2017-07-10 22:37:58 -04:00
Jiri Danek
60fad35cfe ARTEMIS-1244 propagate retain flag of received message 2017-06-22 12:00:40 -04:00
Helge Waastad
eaadc24729 ARTEMIS-1243 Release ReferenceCounted messages 2017-06-21 11:19:09 -04:00
Clebert Suconic
f63ffc7af5 ARTEMIS-1175 Fixing Memory Leak 2017-05-26 11:16:41 +01:00
Odyldzhon Toshbekov
b136fed48f ARTEMIS-1175 fix memory leak 
This closes #1292
 2017-05-26 11:16:41 +01:00
Clebert Suconic
dc26ac96b4 ARTEMIS-1156: moving our collections on its own package 2017-05-12 10:06:05 -04:00
Aditya Sharad
33c94635bf ARTEMIS-1135: Fix integer multiplication overflows 
Multiplication operations where the operands have type `int` but the
result is cast to `long` may lead to overflow.
Fixes two instances of this problem, by ensuring the operands are cast
to `long` during multiplication.
This resolves the "Result of integer multiplication cast to long"
alerts at https://lgtm.com/projects/g/apache/activemq-artemis/alerts.
 2017-05-02 13:00:46 -04:00
Martyn Taylor
1c84bd39c4 ARTEMIS-826 Fix MQTT protocol detection 2017-04-25 13:53:21 +01:00
Howard Gao
f344c1ebaf ARTEMIS-1093 Full qualified queue name support 
Broker should support full qualified queue names (FQQN)
as well as bare queue names. This means when clients access
to a queue they have two equivalent ways to do so. One way
is by queue names and the other is by FQQN (i.e. address::qname)
names. Currently only receiving is supported.
 2017-04-23 16:01:20 -04:00
Clebert Suconic
b395504e15 ARTEMIS-1077 Fixing Pool usage on InVM and RemotingConnection 2017-03-28 09:19:57 -05:00
Martyn Taylor
e33b7af5ac ARTEMIS-1061 Ack MQTT PubRel management messages 2017-03-22 23:26:32 -04:00
Martyn Taylor
b33fea0d7f ARTEMIS-990 Dont require Perms on MQTT mngment Q 2017-03-10 11:06:05 +00:00
Clebert Suconic
fe0ca4d84f ARTEMIS-1009 Pure Message Encoding. 
with this we could send and receive message in their raw format,
without requiring conversions to Core.

- MessageImpl and ServerMessage are removed as part of this
- AMQPMessage and CoreMessage will have the specialized message format for each protocol
- The protocol manager is now responsible to send the message
- The message will provide an encoder for journal and paging
 2017-03-05 23:08:53 -05:00
Martyn Taylor
8b51ec27db NO-JIRA Send MQTT WILL outside of Server Session 2017-02-18 13:31:57 +00:00
Martyn Taylor
5a235d98b6 ARTEMIS-974 ensure will messages are retained 2017-02-16 18:22:10 +00:00
Dejan Bosanac
21b64b3e4f https://issues.apache.org/jira/browse/ARTEMIS-815 - support wildcard address configuration in mqtt layer 
https://issues.apache.org/jira/browse/ARTEMIS-815 - support wildcard address configuration in mqtt layer - remove old swap method

https://issues.apache.org/jira/browse/ARTEMIS-815 - added tests for mqtt-openwire integration and fixed openwire layer

https://issues.apache.org/jira/browse/ARTEMIS-815 - remove unused imports
 2017-02-16 17:37:50 +00:00
Martyn Taylor
bd1f244dfc NO-JIRA Clean up around MQTTConnectionManager 2017-02-14 11:26:54 -06:00
Martyn Taylor
3bd5c9df6a ARTMEIS-958 Route Will message outside server session 2017-02-14 11:26:54 -06:00
Martyn Taylor
59773c2849 ARTEMIS-960 Do not encode Will messages 2017-02-14 11:26:54 -06:00
Justin Bertram
ff3e75d148 NO-JIRA move RoutingType to different package 2017-02-13 09:50:41 -06:00
Martyn Taylor
cd28d76554 ARTEMIS-951 Auto Commit MQTT Acks 2017-02-09 10:43:03 +00:00
Martyn Taylor
b2e250d425 ARTEMIS-952 Remove MQTT Queues on Clean Session 2017-02-09 10:43:03 +00:00
Martyn Taylor
3900cb0ec7 ARTEMIS-917 Only return body of retained message after reboot 2017-02-06 13:33:26 -06:00
Will Reichert
3347a4fd27 ARTEMIS-928 Changing Netty and InVM to copy buffers, and retain them on the Netty Polls. 2017-01-18 16:59:32 -05:00
Martyn Taylor
7f658cad21 ARTEMIS-788 Enable auto create and Prefix in MQTT 2016-12-13 15:54:50 -05:00
jbertram
fa67d40b9d ARTEMIS-789 Fixed a number of failing tests 2016-12-09 18:43:15 +00:00
Martyn Taylor
8f532cc25d ARTEMIS-880 Add support for address prefixing 2016-12-09 18:43:15 +00:00
jbertram
683ae68989 ARTEMIS-789 Fix Failing Tests 2016-12-09 18:43:15 +00:00
Martyn Taylor
7a51491c32 ARTEMIS-780 Added ability to define 2 Routing Types on a single addres 2016-12-09 18:43:15 +00:00
jbertram
a88853fe53 ARTEMIS-788 Stomp refactor + track autocreation for addresses 2016-12-09 18:43:15 +00:00
Martyn Taylor
887b8c8532 ARTEMIS-788 Update MQTT Protocol 2016-12-09 18:43:15 +00: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