Justin Bertram
b48037a1e6
ARTEMIS-3764 wrong CONNACK return code for MQTT5
...
This bug is causing tests in o.a.a.a.t.i.m.s.c.ConnectTestsWithSecurity
to fail.
This commit fixes the problem by setting the session's version earlier
in the logic handling the CONNECT packet so that the proper CONNACK
return code can be supplied to the remote client in case of
authentication failure.
2022-04-06 17:02:19 -04:00
AntonRoskvist
bb44e37e84
ARTEMIS-3733 - Destination cache size too small for OpenWire clients
2022-03-30 11:15:25 -05:00
Clebert Suconic
a0e7cb4eae
[maven-release-plugin] prepare for next development iteration
2022-03-22 13:34:58 -04:00
Clebert Suconic
d57ac487c7
[maven-release-plugin] prepare release 2.21.0
2022-03-22 13:34:55 -04:00
Justin Bertram
3627ba57c9
ARTEMIS-3711 support AMQ_SCHEDULED_DELAY for OpenWire clients
2022-03-21 18:49:48 -04:00
Clebert Suconic
0966f2d7a0
ARTEMIS-3720 Max Number Of Messages on a deciding policy for paging (global and address-settings)
2022-03-18 16:27:46 -04:00
Justin Bertram
2b5a25a106
ARTEMIS-3702 auth failures don't adhere to MQTT spec
...
The commit includes the following changes:
- Don't drop the connection on subscribe or publish authorization
failures for 3.1 clients.
- Don't drop the connection on subscribe authorization failures for
3.1.1 clients.
- Add configuration parameter to control behavior on publish
authorization failures for 3.1.1 clients (either disconnect or not).
2022-03-15 15:33:54 -04:00
Clebert Suconic
861fe59124
ARTEMIS-3721 AMQP Mirrored Large Message file not removed
2022-03-15 08:56:32 -04:00
nbrendah
7bee0d8923
ARTEMIS-3686: Adding example showing how to do telemetry support
...
This is adding an example intercepting and sending messages using opentelemetry to either Jaeger, zipkin or OTLP exporter
2022-03-03 11:08:53 -05:00
gtully
dcaebfb24e
ARTEMIS-3660 - rename broker-balancer to connection-router
2022-03-01 11:15:16 +01:00
Justin Bertram
c4ebccd94d
ARTEMIS-3696 avoid null prop values on STOMP msgs
2022-02-28 13:44:45 -05:00
Justin Bertram
40acb18f4e
ARTEMIS-3698 avoid byte[] prop values when converting from OpenWire
...
Avoid storing the following values as byte[] for OpenWire:
- Marshalled properties. We already store the unmarshalled properties
so this is altogether redundant.
- Producer ID.
- Message ID.
- Various destination values.
Also, eliminate the "original transaction ID" conversion code as it's
never actually set from the incoming message.
2022-02-28 08:41:36 -05:00
AntonRoskvist
8a9f326b25
ARTEMIS-3647 - OpenWire, remove rolledbackMessageRef on Ack
2022-02-17 14:36:39 -06:00
Justin Bertram
27d018327a
ARTEMIS-3678 return proper CONNACK code when MQTT 3.x auth fails
2022-02-10 10:30:44 -06:00
Justin Bertram
51a25b4ba4
ARTEMIS-3677 mitigate NPE when browsing messages
2022-02-10 10:30:03 -06:00
AntonRoskvist
263b723726
ARTEMIS-3646 - OpenWire, Fix overflowing prefetch and incorrect metrics for messages sent to DLQ
2022-02-04 13:40:32 -05:00
Justin Bertram
8063110644
ARTEMIS-3638 Support MQTT 5
...
MQTT 5 is an OASIS standard which debuted in March 2019. It boasts
numerous improvments over its predecessor (i.e. MQTT 3.1.1) which will
benefit users. These improvements are summarized in the specification
at:
https://docs.oasis-open.org/mqtt/mqtt/v5.0/os/mqtt-v5.0-os.html#_Toc3901293
The specification describes all the behavior necessary for a client or
server to conform. The spec is highlighted with special "normative"
conformance statements which distill the descriptions into concise
terms. The specification provides a helpful summary of all these
statements. See:
https://docs.oasis-open.org/mqtt/mqtt/v5.0/os/mqtt-v5.0-os.html#_Toc3901292
This commit implements all of the mandatory elements from the
specification and provides tests which are identified using the
corresponding normative conformance statement. All normative
conformance statements either have an explicit test or are noted in
comments with an explanation of why an explicit test doesn't exist. See
org.apache.activemq.artemis.tests.integration.mqtt5 for all those
details.
This commit also includes documentation about how to configure
everything related to the new MQTT 5 features.
2022-02-04 09:57:15 -05:00
Robbie Gemmell
8661cecb8f
ARTEMIS-3655: isolate the errorprone dependencies to its profiles, enable everywhere, fix related problems, and update to 2.10.
2022-01-26 16:32:34 +00:00
Domenico Francesco Bruscino
9c01f9b983
ARTEMIS-3649 Fix zero prefetch OpenWire consumers
2022-01-19 10:14:08 +00:00
Erwin Dondorp
d02c8cd16f
ARTEMIS-3623 preserve type of numeric extraProperties
2022-01-07 13:17:39 -05:00
Clebert Suconic
e34677f5c0
[maven-release-plugin] prepare for next development iteration
2021-12-14 22:50:55 -05:00
Clebert Suconic
3dea7eeb71
[maven-release-plugin] prepare release 2.20.0
2021-12-14 22:50:53 -05:00
Clebert Suconic
1e62979577
ARTEMIS-3604 Async sends overflowing server in OpenWire
2021-12-10 15:49:26 -05:00
gtully
dcb6292def
fix intermittent failure of org.apache.activemq.artemis.tests.integration.client.ConsumerTest#testSendAMQPReceiveCore
2021-12-09 10:12:39 +00:00
Domenico Francesco Bruscino
3f7f8c0ecd
ARTEMIS-3576 Fix toString methods throwing exceptions
2021-12-03 13:15:44 -05:00
franz1981
7e6373d4df
ARTEMIS-3578 Save SimpleString duplication and long[] allocation while moving Core messages
2021-12-01 10:27:46 +01:00
Clebert Suconic
12a93e3c7e
Revert "ARTEMIS-3576 Fix toString methods throwing exceptions"
...
This reverts commit fcd512f9de
.
this will be re-applied after fixing the build and tests
2021-11-29 13:21:24 -05:00
Domenico Francesco Bruscino
fcd512f9de
ARTEMIS-3576 Fix toString methods throwing exceptions
2021-11-29 12:02:58 -05:00
Domenico Francesco Bruscino
f8472fd736
ARTEMIS-3569 Validate users on AMQP remote open
2021-11-24 11:28:16 +01:00
gtully
b979189187
ARTEMIS-3569 - balancer role_name local target, matches role of authenticated user
2021-11-24 11:28:16 +01:00
Erwin Dondorp
dde48d052f
ARTEMIS-3556 show message protocol on message-view page
2021-11-10 20:46:55 -05:00
Domenico Francesco Bruscino
8e92fd0f51
ARTEMIS-3559 Update netty version to 4.1.70.Final
2021-11-09 10:08:02 +01:00
Clebert Suconic
657e4bf842
ARTEMIS-3538 Removing some extra // ----
2021-11-04 08:43:14 -04:00
Clebert Suconic
6de637259b
ARTEMIS-3553 -5718 Conversion of AMQP large message expiry
2021-11-03 21:28:56 -04:00
Clebert Suconic
8b3663e827
ARTEMIS-3538 Removing a few extra // ----- structural comments
2021-11-02 21:45:09 -04:00
Asukwo-comfort
923e4cc892
ARTEMIS-3538: Removing // --------- comments from the codebase
2021-11-02 21:44:12 -04:00
Robbie Gemmell
3f9de5fa30
ARTEMIS-3461: add some tests and resolve various issues spotted with the prior changes
...
- Avoid blowing up on string bodies of any size if the valueSizeLimit bits are configured to disable limit
- Dont NPE if amqp-value + binary body is sent without a content-type, as it always should be.
- Include expected prefix when adding delivery delay and ingress time annotations.
- Use the actual name for ingress time annotation, as with all other annotations.
- Use correct object type when testing equality with content-type value.
- Use consistent case for 'groupId' in different properties.
2021-11-01 17:08:15 -04:00
Clebert Suconic
3191d0c929
ARTEMIS-3461 Fixing Typo on Creation Time
2021-10-21 15:34:18 -04:00
Clebert Suconic
1db3ae1dc0
ARTEMIS-3529 Fixing integration tests after Web Console Parsing of Large Messages
2021-10-19 23:00:51 -04:00
Clebert Suconic
54418dfcaf
ARTEMIS-3529 Fixing test and tweaks on properties
2021-10-19 17:43:01 -04:00
Clebert Suconic
6bb4aa7a10
ARTEMIS-3529 Moving addItem from AMQP and Core into upper class
2021-10-17 20:06:51 -04:00
Clebert Suconic
a833d95c1f
ARTEMIS-3461 Generalize MBean Support on Messages and avoid converstion to core on AMQP Messages on console browsing
...
Done in collaboration with Erwin Dondorp through https://github.com/apache/activemq-artemis/pull/3794/
2021-10-17 11:25:27 -04:00
Justin Bertram
402842062a
[maven-release-plugin] prepare for next development iteration
2021-10-11 13:35:57 -05:00
Justin Bertram
5fcb763234
[maven-release-plugin] prepare release 2.19.0
2021-10-11 13:35:06 -05:00
Robbie Gemmell
d7f37ae313
ARTEMIS-3520: set the Open failure hint when balancer redirects or refuses AMQP connection, add lower level test for balancer related redirect/refusal protocol behaviour
2021-10-07 10:55:29 +01:00
Clebert Suconic
15c2dbb1c3
ARTEMIS-3521 Option to disable duplicate detection on openwire failover clients
2021-10-06 16:26:01 -04:00
Clebert Suconic
481b73c8ca
ARTEMIS-3502 Auto delete & auto create leading to inconsistencies
2021-10-05 17:53:30 -04:00
Clebert Suconic
557506140f
ARTEMIS-3457 Dealing with String conversions
...
The test I wrote for ARTEMIS-3513 is throwing a few convert exceptions
because of SimpleString versus String conversion
This commit is addressing the issue,
The previous commit (the one addressing ARTEMIS-3513) should provide the test for this change.
2021-10-05 11:44:24 -04:00
Emmanuel Hugonnet
fa439375e9
[ARTEMIS-3494]: ActiveMQClientProtocolManagerFactory shouldn't have a private constructor.
...
* Removing the 'private' constructor
* Removing the use of a static getInstance
Issue: https://issues.apache.org/jira/browse/ARTEMIS-3494
2021-09-23 11:28:06 +02:00
Clebert Suconic
c3b403a980
ARTEMIS-3482 Removing non used methods and some reorg on message methods
2021-09-15 09:17:01 -04:00
Clebert Suconic
14457c4308
ARTEMIS-3464 Protecting scheduled tasks counter with a synchronized
2021-09-13 14:35:45 -04:00
Clebert Suconic
2fb23474ce
ARTEMIS-3464 Improving ACK reliability on Paging and code improvements
2021-09-10 18:27:00 -04:00
Clebert Suconic
43ca9540be
ARTEMIS-3472 Reconnect openwire could leave Openwire internal session null
2021-09-10 18:07:11 -04:00
Justin Bertram
8f6dd3ea37
ARTEMIS-3471 implement "session present" for MQTT CONNACK
2021-09-10 14:41:02 -05:00
Robbie Gemmell
55fb9bb540
ARTEMIS-3449: add some additional guarding following behaviour seen prior to ARTEMIS 3465 fix
2021-09-10 11:41:21 +01:00
Domenico Francesco Bruscino
9ed12b53d6
ARTEMIS-3467 FD leak on receiving AMQP large messages
2021-09-09 16:56:52 -04:00
Robbie Gemmell
8fb5b8969f
ARTEMIS-3449: fix some issues from using position to track an unrelated state, plus simplify some previous changes and more
2021-09-09 10:37:36 +01:00
Clebert Suconic
7fb4f80649
ARTEMIS-3464 Missing ACKs on Page and Mirror
2021-09-08 15:30:39 -04:00
franz1981
a4c311f368
ARTEMIS-3449 Speedup AMQP large message streamig
2021-09-08 15:22:22 -04:00
gtully
224b89810d
ARTEMIS-2007 - allow redistribution if there are unmatched messages pending on a queue and there is new remote demand
2021-09-06 10:40:39 +01:00
Justin Bertram
13df6a8fb9
ARTEMIS-3457 log WARN for OpenWire property conversion problem
...
While converting a core message to an OpenWire message there may be an
error processing a property value. Currently this results in an
exception and the message is not dispatched to the client. The broker
eventually attempts to redeliver this message resulting in the same
error. Instead of throwing an exception the broker should simply log a
WARN message and skip the property. This will allow clients to receive
the message without the problematic property and the broker will not
have to attempt to redeliver the message again.
2021-09-03 16:51:02 -04:00
Justin Bertram
6ee7e72db1
ARTEMIS-3445 automatically clean-up abandoned MQTT subscriptions
2021-09-03 16:48:01 -04:00
Robbie Gemmell
9b074e124e
ARTEMIS-3459: use appropriate call to clear up, avoid creating unnecessary wrapper
2021-09-03 18:06:21 +01:00
Clebert Suconic
8709b1e5d3
ARTEMIS-3448 Expiry (maybe DLQ copy) would break LargeMessage Delivery
...
This commit will fix MessagesExpiredPagingTest.testSendReceiveAMQPLarge
2021-08-27 16:33:30 -04:00
Andy Taylor
364d4cc324
ARTEMIS-3426 - fix copying of large retained message
...
https://issues.apache.org/jira/browse/ARTEMIS-3426
2021-08-19 09:58:28 -04:00
Andy Taylor
191cb34c54
ARTEMIS-3423 - create correct queue when durable subs recreated via AMQP
...
https://issues.apache.org/jira/browse/ARTEMIS-3423
2021-08-18 12:41:19 -04:00
Clebert Suconic
b8c64590f9
[maven-release-plugin] prepare for next development iteration
2021-08-09 11:58:28 -04:00
Clebert Suconic
37cc298973
[maven-release-plugin] prepare release 2.18.0
2021-08-09 11:58:27 -04:00
Clebert Suconic
cc4a51a3ea
[maven-release-plugin] prepare for next development iteration
2021-08-06 17:04:18 -04:00
Clebert Suconic
0b30187091
[maven-release-plugin] prepare release 2.18.0
2021-08-06 17:04:16 -04:00
Clebert Suconic
0e2ce484ba
[maven-release-plugin] prepare for next development iteration
2021-08-06 13:46:56 -04:00
Clebert Suconic
cb705b5c5c
[maven-release-plugin] prepare release 2.18.0
2021-08-06 13:46:54 -04:00
Domenico Francesco Bruscino
3555dd7d25
ARTEMIS-3365 Add broker balancers
2021-08-06 08:33:21 -04:00
gtully
c2da0fd663
ARTEMIS-3200 - remove braces from the belt and braces fix in ARTEMIS-2712, the braces are not necessary and leak, cleaning up in close negates the need to the session closeable
2021-08-05 09:27:12 -04:00
Clebert Suconic
813ed88ecb
ARTEMIS-3243 Implementing dual mirror with Broker Connections
...
There are some major tests added as part of this PR.
This PR has been done through an extensive collaboration with Robbie Gemmel on https://github.com/apache/activemq-artemis/pull/3633
2021-08-03 16:50:43 -04:00
Robbie Gemmell
d9a44002c5
ARTEMIS-3304: replace use of deprecated constructors marked as for-removal since Java 16
...
updates all the uses in tests, missed in original commit
2021-07-27 14:55:40 +01:00
Domenico Francesco Bruscino
51801d978e
ARTEMIS-3396 Convert bytes properties to String for OpenWire
2021-07-22 11:23:28 -04:00
Clebert Suconic
18e9dee490
NO-JIRA Small tweaks on AMQPMessage.
...
- adding annotations into toString()
- comment typo
2021-07-13 08:28:06 -04:00
Clebert Suconic
ee3814dbfd
ARTEMIS-3383 AMQPMessage.isDurable wrongly returns false during persistent lazy reload state
2021-07-12 23:00:16 -04:00
Justin Bertram
ec508d8306
ARTEMIS-3381 AMQP bypasses session when deleting queues
...
The AMQP implementation bypasses the ServerSession when deleting queues
which also bypasses security authorization.
2021-07-12 11:25:11 -04:00
Justin Bertram
bf875c3a37
ARTEMIS-3374 fix tests and shared subscriber case
...
A couple of tests were explicitly written to delete the
configuration-managed queue. Since this is no longer allowed these
tests had to change.
2021-07-12 11:25:11 -04:00
gtully
7fc312ab5d
ARTEMIS-3372 - disconnect consumers on queue deletion event
2021-07-06 16:16:33 -04:00
Justin Bertram
b7f9807cd9
ARTEMIS-2919 support timestamping incoming messages
2021-07-06 14:09:00 -05:00
Justin Bertram
1d02d06eab
ARTEMIS-3374 config-managed queue can be deleted by durable subscriber
2021-07-06 14:06:39 -05:00
Justin Bertram
a4c1155a01
ARTEMIS-3341 update checkstyle to latest + update code
...
As a follow-up to #3618/dc7de893747b90b627d729f9f18a758bb4dad9d5 update
checkstyle to the latest version, restoring the originally intended
"RightCurly" style, and updating all the code to properly adhere to the
style as enforced by the new checkstyle version.
The version of checkstyle we used before the aforementioned commit had
a bug which didn't properly enforced our intended "RightCurly" style
(see https://github.com/checkstyle/checkstyle/issues/6345 ). That commit
changed the style to accommodate the handful of unintended style
violations. This commit reverts that change for 2 main reasons:
- The style was always intended to use `alone` for both `METHOD_DEF`
and `CTOR_DEF`.
- There are over 1,000 existing uses of the intended style and around
30 violations of this style which were unintentionally allowed.
Reverting the style back to the original and cleaning up the unintented
violations makes the code more consistent and prevents further style
inconsistencies in the future.
There were a handful of other changes related to checkstyle bugs which
allowed unintended style violations. These were related to indentation
levels.
This closes #3619
(with some minor changes from Robbie to fix remaining violations)
2021-06-11 12:16:04 +01:00
Domenico Francesco Bruscino
bafefdc8ec
ARTEMIS-3338 Preserve prepared XA transactions on connection failure
2021-06-09 15:00:45 -04:00
gtully
0e77f93f83
ARTEMIS-3326 - fix state visibility between netty and actor thread after initial connection info processing. fix and test
2021-06-03 09:37:23 +01:00
gtully
815f383f9c
ARTEMIS-3234 - revisit fix to deal with credit on unmatched acks, thanks to brusdev for the interceptor feature and test from ARTEMIS-2650
2021-06-02 16:23:46 +01:00
gtully
7ce9030e9f
ARTEMIS-3323 - ensure openwire message id is unique and consistent for the life of a broker when converted from core
2021-06-01 19:43:25 +01:00
Justin Bertram
cdaa00d470
ARTEMIS-3317 OpenWire property conversion can cause ClassCastException
2021-05-27 09:52:49 -04:00
Domenico Francesco Bruscino
6ec7a69d45
ARTEMIS-3236 Preserve managed queues on removing MQTT subscription
2021-05-25 11:24:53 -05:00
Justin Bertram
79c9364e65
ARTEMIS-3237 logging OpenWire producer exception is confusing
...
Logging the exception here is potentially confusing for two main
reasons:
1. It's not clear the exception is specifically for the client.
2. There is likely other logging that identifies the problem.
2021-05-24 12:14:22 -05:00
Andy Taylor
a34d9aad6b
ARTEMIS-3295 - do not cluster advisories
...
https://issues.apache.org/jira/browse/ARTEMIS-3295
2021-05-14 10:08:21 -04:00
gtully
0f3d87799a
ARTEMIS-3240 - ensure pending transactions are rolled back on connection failure. Fix and test
2021-04-16 10:22:06 -04:00
Robbie Gemmell
3c90c695f3
ARTEMIS-3106: remove duplicate artemis-server dependency added in 5313a800a3
...
Resolves related build warning it caused.
2021-04-14 12:45:46 +01:00
Clebert Suconic
d408f284b1
ARTEMIS-3238 AMQP Mirror not routing correctly with SNF
2021-04-12 19:30:35 -04:00
gtully
fa80c03049
ARTEMIS-3234 - fix and test, the existing tests suffered with suppressInternalManagementObjects defaulting to true. credit accounting is now independent of the ack list such that preack for advisories can work
2021-04-12 08:29:58 -04:00
Domenico Francesco Bruscino
b4789a894f
ARTEMIS-3221 Migrating to Jakarta EE 8 artifacts
2021-04-09 11:49:59 -04:00
Christoph Läubrich
5313a800a3
ARTEMIS-3106 Support for SASL-SCRAM
...
adds the implementation necessary to perform SASL-SCRAM authentication with ActiveMQ Artemis
2021-04-08 19:58:09 -04:00
gtully
02bb7031c2
ARTEMIS-3175 - implement address setting management-message-attribute-size-limit to sensibly limit data returned by list/browse/filter management ops
2021-03-23 09:48:45 +00:00
gtully
8fd1b33d16
ARTEMIS-3197 - add selectorAware option to virtualTopicConsumerWildcards for openwire acceptor
2021-03-22 19:15:02 -04:00
Clebert Suconic
b4beea1f2c
ARTEMIS-3150 Broker Connections with restricted security
...
The local connections and sessions created internally were supposed to bypass security
just like bridges and other internal components
2021-03-22 17:32:43 -04:00
Justin Bertram
e1669d4ad2
ARTEMIS-3172 don't log STOMP CONNECT passcode header
2021-03-17 09:53:22 -05:00
Robbie Gemmell
96a09041ee
ARTEMIS-3183: resolve various immediate warnings at build start
...
- Remove duplicates dependency definition following e7e3c71511
.
- Removes deprecated RELEASE version use, consolidate modules on single paho client version.
- Remove prerequisites entry as per warning, suggested enforcer rule already in place.
2021-03-16 12:48:48 +00:00
Justin Bertram
e548e0aab2
ARTEMIS-3182 remove defunct repo
...
This repo is no longer operative. See
https://jfrog.com/blog/into-the-sunset-bintray-jcenter-gocenter-and-chartcenter/
for more info. All dependencies are in Maven Central.
2021-03-15 20:00:09 -05:00
Justin Bertram
eb26f67ab6
ARTEMIS-3137 support XPath filters
...
Change summary:
- Remove the existing Xalan-based XPath evaluator since Xalan appears
to be no longer maintained.
- Implement a JAXP XPath evaluator (from the ActiveMQ 5.x code-base).
- Pull in the changes from https://issues.apache.org/jira/browse/AMQ-5333
to enable configurable XML parser features.
- Add a method to the base Message interface to make it easier to get
the message body as a string. This relieves the filter from having
to deal with message implementation details.
- Update the Qpid JMS client to get the jms.validateSelector parameter.
2021-03-10 09:32:23 -05:00
gtully
a0ce3812ba
ARTEMIS-3067, ARTEMIS-3135 - rework accounting for lazy decoding by directly referencing the owning page store, owner now tracked on a message rather than the message reference. This avoids the error prone checks around potential decoding sites
2021-02-24 15:50:13 +00:00
Clebert Suconic
12c8096a23
ARTEMIS-3093 Ordering on multiple consumers and core with rollback
2021-02-22 15:10:04 -05:00
Domenico Francesco Bruscino
ab7058ac75
ARTEMIS-3118 Fix the expiration on converting from AMQP to core
...
Initialize the JMS expiration with the value calculated during the scan
of the AMQP message to avoid a different value for each conversion based
on System.currentTimeMillis() and ttl.
2021-02-17 17:34:20 +01:00
Clebert Suconic
7d10e915b6
ARTEMIS-3116 Fixing Core->AMQP Conversion of Scheduled Delivery Time
2021-02-12 13:00:06 -05:00
Clebert Suconic
21ee5985ea
[maven-release-plugin] prepare for next development iteration
2021-02-11 12:00:04 -05:00
Clebert Suconic
36a771150b
[maven-release-plugin] prepare release 2.17.0
2021-02-11 11:59:51 -05:00
Clebert Suconic
e7e3c71511
ARTEMIS-3113 - Artemis AMQP shouldn't depend on JMS.
...
* removing the JMS dependency on AMQP module
* fixing destinations usage.
* refactoring to remove some JMS usage and make exceptions a bit better
Jira: https://issues.apache.org/jira/browse/ARTEMIS-3113
2021-02-11 10:45:01 -05:00
Clebert Suconic
7f64822591
Revert "[ARTEMIS-3113]: Artemis AMQP shouldn't depend on JMS."
...
This reverts commit 5079ad1019
.
2021-02-10 18:34:25 -05:00
Clebert Suconic
5079ad1019
[ARTEMIS-3113]: Artemis AMQP shouldn't depend on JMS.
...
* removing the JMS dependency on AMQP module
* fixing destinations usage.
Jira: https://issues.apache.org/jira/browse/ARTEMIS-3113
2021-02-10 12:47:38 -05:00
Clebert Suconic
c0867f0361
[maven-release-plugin] prepare for next development iteration
2021-02-09 12:12:48 -05:00
Clebert Suconic
9b473698e0
[maven-release-plugin] prepare release 2.17.0
2021-02-09 12:12:35 -05:00
Clebert Suconic
6ed1e4c87d
[maven-release-plugin] prepare for next development iteration
2021-02-08 15:56:31 -05:00
Clebert Suconic
06b29806ca
[maven-release-plugin] prepare release 2.17.0
2021-02-08 15:56:18 -05:00
Christoph Läubrich
0bedb3048a
ARTEMIS-33 Generic integration with SASL Frameworks
...
This adds the opportunity to register new SASL schemes via the default
java service-loader mechanism.
Implementors have to provide an implementation of the ServerSASLFactory
that is responsible for providing instances of the actual scheme.
2021-02-07 11:18:13 -05:00
岳豹
9c5ec1b07c
ARTEMIS-3105 large message file not closed on backup side
2021-02-07 10:41:41 +08:00
Domenico Francesco Bruscino
267c6e5b56
ARTEMIS-3091 Fix AMQP message headers export from the journal
2021-02-01 11:54:37 -05:00
gtully
d186d20406
ARTEMIS-3067 - track application properties in memory estimate and check for modification after potential filter execution
2021-02-01 09:21:17 -05:00
Domenico Francesco Bruscino
9d070812dd
ARTEMIS-3079 Fix AMQP binary properties serialization to JSON
2021-01-25 13:22:53 -06:00
Clebert Suconic
78c0792989
ARTEMIS-3065 AMQP Anonymous producer would eventually block
2021-01-13 15:46:54 -05:00
franz1981
2e0f051d2d
ARTEMIS-3063 AMQPMessage get property can use a String switch
2021-01-12 12:07:23 +01:00
franz1981
dc68d2e08f
ARTEMIS-3061 AMQPMessage::getDuplicateProperty can save key comparisons and class checks
2021-01-11 21:42:54 -05:00
franz1981
be3812b2e2
ARTEMIS-3059 AMQP message reencoding should save creating Netty heap arenas
2021-01-11 11:37:30 -05:00
Domenico Francesco Bruscino
92d6ae87ed
ARTEMIS-3027 Fixing AMQP persister encoding
2020-12-22 10:37:34 -05:00
Clebert Suconic
57c9dc623c
ARTEMIS-3035 Log.info on connection success for AMQP Broker Connection
2020-12-16 13:41:32 -05:00
Clebert Suconic
3b0fa74970
ARTEMIS-3027 Fixing tests after some large messages changes
2020-12-14 15:19:12 -05:00
Clebert Suconic
63a3bcbe32
ARTEMIS-3027 Fixing Redistribution of Large Messages after expiration fix
...
This is fixing AmqpLargeMessageRedistributionTes and AMQPLargeMessageOverCoreBridgeTest after last commit on this issue.
2020-12-14 11:18:38 -05:00
Clebert Suconic
dfd41d958e
ARTEMIS-3027 Store calculated expiration as part of the journal record on AMQP
2020-12-10 18:33:15 -05:00
Clebert Suconic
94f1857914
ARTEMIS-3026 Allow "re-encode" of amqp large messages
...
notice the quotes on "re-encode", as this is just replacing the set of application properties, properties and headers by a new set
if a flag reEncoded is set to true on AMQPLargeMessage
2020-12-10 00:37:11 -05:00
Clebert Suconic
825341734a
ARTEMIS-3024 Expiry or DLQ Retry not working with AMQP
2020-12-08 14:13:53 -05:00
Clebert Suconic
6a6a3b3863
ARTEMIS-3023 Avoid opening AMQP Large Message for final parsing
2020-12-07 21:24:45 -05:00
Clebert Suconic
e6a6e81b02
ARTEMIS-3019 expiry changes in AMQP Large Message
2020-12-07 10:44:51 -05:00
Clebert Suconic
ccefbfcfa9
ARTEMIS-3019 Before applying the fix into two methods, I needed to move the method into the right place
...
There is no real change in this commit other than moving the methods to the right place
2020-12-07 10:30:03 -05:00
Clebert Suconic
e75a679dec
ARTEMIS-2985 Ordered Executor not needed on Actor
...
The Actor is already an ordered executor. No need to create one here.
2020-11-20 10:42:07 -05:00
gtully
9675ecae42
ARTEMIS-2985 - don't block netty threads for mqtt protocol actions
2020-11-12 21:01:00 +00:00
Clebert Suconic
ead05b7a89
ARTEMIS-2983 Fixing PrintData with AMQP
2020-11-11 12:47:02 -05:00
Domenico Francesco Bruscino
14ec3cb7b0
ARTEMIS-2976 Remove password before creating server locator
2020-11-05 11:39:35 -05:00
Robbie Gemmell
5ff075b7ff
ARTEMIS-2971: add ANONYMOUS and EXTERNAL SASL mechanism support for outgoing AMQP server connections
2020-11-05 11:32:35 -05:00
Clebert Suconic
4e7bb97df7
[maven-release-plugin] prepare for next development iteration
2020-11-02 17:45:51 -05:00
Clebert Suconic
9768017530
[maven-release-plugin] prepare release 2.16.0
2020-11-02 17:45:38 -05:00
Clebert Suconic
648340a864
ARTEMIS-2969 / ARTEMIS-2937 Making sure consumers are cleaned after failures and reconnects
2020-11-02 17:24:45 -05:00
Clebert Suconic
7a435a944c
ARTEMIS-2969 / ARTEMIS-2937 should set connecting = false when maxRetry is reached
2020-11-02 13:13:15 -05:00
Clebert Suconic
fa4064cfd7
ARTEMIS-2969 / ARTEMIS-2937 RedoConnection should call protonRemotingConnection.destroy
...
Instead of calling destroy, redo was closing the Netty connection directly leaving the job of destroy delayed until TTL
2020-11-02 11:40:10 -05:00
Andy Taylor
dafef2b267
ARTEMIS-2973 - JMS AMQP Shared global subscriber queue not deleted on unsubscribe
...
https://issues.apache.org/jira/browse/ARTEMIS-2973
2020-11-02 10:00:13 -05:00
Clebert Suconic
c0b12b14c8
ARTEMIS-2969 / ARTEMIS-2937 Controlling connecting state on AMQP Broker Connection
...
- Fixed an issue where I needed to set connection to null after closing it
- Added more tests on QpidDispatchPeerTest (tests i would have done manually, and reproduced a few issues along the way)
2020-11-02 09:54:21 -05:00
Clebert Suconic
28919b6ad8
[maven-release-plugin] prepare for next development iteration
2020-10-30 10:16:29 -04:00
Clebert Suconic
af5ca9f1e6
[maven-release-plugin] prepare release 2.16.0
2020-10-30 10:16:17 -04:00
Clebert Suconic
f3dde91b91
ARTEMIS-2969 / ARTEMIS-2937 Dealing with instant disconnects on amqp broker connections
2020-10-30 09:52:03 -04:00
Clebert Suconic
dff2ed3638
ARTEMIS-2937 Implementing skip create and skip delete on Mirror Source
2020-10-30 08:44:51 -04:00
Clebert Suconic
981b516479
ARTEMIS-2968 Ignoring expected exception when deleting a previously already removed queue
2020-10-29 22:04:33 -04:00
Clebert Suconic
480197975b
ARTEMIS-2967 Adding testSimpleConnect back and fixing a possible NPE
2020-10-29 22:01:01 -04:00
Clebert Suconic
9b0f7605cb
ARTEMIS-2969 / ARTEMIS-2937 Dealing with Connection Timeout properly on AMQP Broker Connections
2020-10-29 21:55:10 -04:00
Clebert Suconic
dc7eb5c23d
ARTEMIS-2937 Broker connection improvements
...
- Adding a paragraph about addressing and distinct queue names
- Renaming match on peers, senders and receivers as "address-match"
- Changing qpid dispatch test to use a single listener
- Fixing reconnect attemps message
2020-10-29 15:01:51 -04:00
Clebert Suconic
d51c89471e
ARTEMIS-2966 Anycast queues with distinct names would cause issues on sending messages
2020-10-29 10:09:36 -04:00
gtully
e5566d5211
ARTEMIS-2964 - fire advisory messages via post office, independent of connection state. consume via regular auth
2020-10-29 09:58:52 +00:00
Clebert Suconic
bf52134dc0
ARTEMIS-2937 Fixing Tests and some review
2020-10-28 15:08:48 -04:00
Clebert Suconic
8499eac76c
ARTEMIS-2937 Server Side AMQP Connectivity with options to transfer queues or replicate data
2020-10-28 11:37:25 -04:00
Justin Bertram
cdc283fba5
ARTEMIS-2915 duplicate temp queues using OpenWire
2020-09-24 12:48:36 -04:00
franz1981
feca90d475
ARTEMIS-2766 Fixing unused stopSet parameter
2020-09-23 15:52:52 -04:00
Robbie Gemmell
6a4e79fd06
ARTEMIS-2910: reuse routing type calculated in initialisation for fixed-address producers
2020-09-23 12:09:18 -04:00
Robbie Gemmell
d9d98dfa8a
ARTEMIS-2910: consider message annotations when determining routing type used for auto-creation with anonymous producers
2020-09-21 18:07:26 +01:00
Justin Bertram
e47eb5ae20
ARTEMIS-589 flow control for individual STOMP subscribers
2020-09-16 10:13:47 -04:00
Clebert Suconic
7cf5289efa
ARTEMIS-2900 Expose property (getWholeMessageSize) so users can intercept size of messages and large messages
2020-09-14 15:35:46 -04:00
Clebert Suconic
4d45d0cdd2
ARTEMIS-2887 Adding toString back to AMQPMessage
2020-08-26 17:54:25 -04:00
Domenico Francesco Bruscino
32bf9680f2
[maven-release-plugin] prepare for next development iteration
2020-08-24 16:03:24 +02:00
Domenico Francesco Bruscino
a549fcedde
[maven-release-plugin] prepare release 2.15.0
2020-08-24 16:03:12 +02:00
Justin Bertram
582a430213
ARTEMIS-2882 better support for JMS topics + FQQN
...
Support FQQN with JMS topics when sending to or consuming from a
specific subscription. This applies to JMS over core, OpenWire,
and AMQP.
2020-08-20 14:32:11 -05:00
Francesco Nigro
70068a0659
ARTEMIS-2844 Save additional copies and use pooled direct ByteBufs
2020-07-30 23:32:10 -04:00
Francesco Nigro
0db13ee8ab
ARTEMIS-2844 Use writeAndFlush with voidPromise to reduce GC pressure
2020-07-30 23:32:10 -04:00
brusdev
18b8df0f09
ARTEMIS-2855 Define a new broker plugin to track XA transactions
2020-07-29 10:40:55 -04:00
Clebert Suconic
6690ba1d24
[maven-release-plugin] prepare for next development iteration
2020-07-09 12:49:08 -04:00
Clebert Suconic
a76f41a7ed
[maven-release-plugin] prepare release 2.14.0
2020-07-09 12:48:54 -04:00
Clebert Suconic
c1be566c20
NO-JIRA Fixing rare intermittent failure on CreditsSemaphoreTest
2020-07-08 12:36:26 -04:00
Justin Bertram
20daf2354c
ARTEMIS-2817 Support Stomp subscription with FQQN+multicast
2020-07-07 08:21:22 -04:00
gtully
4e40b42521
ARTEMIS-2809 retain api used by activemq-cli-tools
2020-06-17 15:20:57 +01:00
Robbie Gemmell
d2c46762e8
ARTEMIS-2109: fix javadoc errors, remove doclint config for JDK8, remove superfluous plugin versions, update to 3.0.1 javadoc plugin
...
Using 3.0.1 like the current apache parent pom [not being used], and also as newer ones break build.
2020-06-11 18:50:01 +01:00
Emmanuel Hugonnet
efe0f468de
ARTEMIS-2109: Updating the build to be able to execute it on Java 11 and Java 8.
2020-06-11 18:50:01 +01:00
Justin Bertram
e1d8f42cc1
ARTEMIS-2798 expiration for AMQP msgs not reloaded
2020-06-09 15:18:45 -04:00
gtully
56dbd91263
ARTEMIS-2788 clear openwire producer exchange, created on send, on producer close event
2020-06-05 10:22:44 +01:00
Clebert Suconic
111b551d79
ARTEMIS-2789 AMQP Large Message Memory Estimate
2020-06-03 23:23:16 -04:00
gtully
1a5b1fbe8e
ARTEMIS-2788 clear openwire producer state on produce close event
2020-06-03 13:33:18 +01:00
Clebert Suconic
faa83b2ba6
[maven-release-plugin] prepare for next development iteration
2020-05-16 18:38:47 -04:00
Clebert Suconic
5f49d89264
[maven-release-plugin] prepare release 2.13.0
2020-05-16 18:38:34 -04:00
Clebert Suconic
1420ad7745
ARTEMIS-2766 Improving AMQPMessageSymbolSearch for correctness
2020-05-16 11:39:21 -04:00
Clebert Suconic
83c7942a78
ARTEMIS-2766 Fixing AMQP Large Messages after Parsing change
2020-05-15 17:57:00 -04:00
Clebert Suconic
c99fcd501b
[maven-release-plugin] prepare for next development iteration
2020-05-15 16:42:54 -04:00
Clebert Suconic
47fafac760
[maven-release-plugin] prepare release 2.13.0
2020-05-15 16:42:41 -04:00
Clebert Suconic
8562e6a1a7
ARTEMIS-2766 Not parsing application properties for duplicate property
2020-05-15 16:17:15 -04:00
Clebert Suconic
9ff3c17525
ARTEMIS-2757 improving flow control in AMQP
2020-05-15 16:12:07 -04:00
Clebert Suconic
4fe4220ff0
ARTEMIS-2372 / ARTEMIS-2740 Improving Message Annotations support in AMQP
...
- when sending messages to DLQ or Expiry we now use x-opt legal names
- we now support filtering thorugh annotations if using m. as a prefix.
- enabling hyphenated_props: to allow m. as a prefix
2020-05-13 10:55:36 -04:00
Clebert Suconic
9571ca16db
ARTEMIS-2753 Expanding wildcard fix to Advisories
2020-05-07 12:16:35 -04:00
Clebert Suconic
c20d894e81
ARTEMIS-2753 Fixing OpenWire Temporary queue names over wildcard configurations
2020-05-06 23:24:24 -04:00
Clebert Suconic
7438d7ff07
ARTEMIS-2750 Fixing out of order cancellations in AMQP
2020-05-04 13:15:56 -04:00
Andy Taylor
8a04ee07de
ARTEMIS-2648 - audit logging improvements
...
https://issues.apache.org/jira/browse/ARTEMIS-2648
2020-05-04 15:19:08 +01:00
Justin Bertram
ede2051960
ARTEMIS-2655 support auto-creation w/FQQN & STOMP
2020-05-01 13:40:24 -05:00