55fb9bb540
ARTEMIS-3449: add some additional guarding following behaviour seen prior to ARTEMIS 3465 fix
2021-09-10 11:41:21 +01:00
9ed12b53d6
ARTEMIS-3467 FD leak on receiving AMQP large messages
2021-09-09 16:56:52 -04:00
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
7fb4f80649
ARTEMIS-3464 Missing ACKs on Page and Mirror
2021-09-08 15:30:39 -04:00
a4c311f368
ARTEMIS-3449 Speedup AMQP large message streamig
2021-09-08 15:22:22 -04:00
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
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
6ee7e72db1
ARTEMIS-3445 automatically clean-up abandoned MQTT subscriptions
2021-09-03 16:48:01 -04:00
9b074e124e
ARTEMIS-3459: use appropriate call to clear up, avoid creating unnecessary wrapper
2021-09-03 18:06:21 +01:00
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
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
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
b8c64590f9
[maven-release-plugin] prepare for next development iteration
2021-08-09 11:58:28 -04:00
37cc298973
[maven-release-plugin] prepare release 2.18.0
2021-08-09 11:58:27 -04:00
cc4a51a3ea
[maven-release-plugin] prepare for next development iteration
2021-08-06 17:04:18 -04:00
0b30187091
[maven-release-plugin] prepare release 2.18.0
2021-08-06 17:04:16 -04:00
0e2ce484ba
[maven-release-plugin] prepare for next development iteration
2021-08-06 13:46:56 -04:00
cb705b5c5c
[maven-release-plugin] prepare release 2.18.0
2021-08-06 13:46:54 -04:00
3555dd7d25
ARTEMIS-3365 Add broker balancers
2021-08-06 08:33:21 -04:00
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
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
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
51801d978e
ARTEMIS-3396 Convert bytes properties to String for OpenWire
2021-07-22 11:23:28 -04:00
18e9dee490
NO-JIRA Small tweaks on AMQPMessage.
...
- adding annotations into toString()
- comment typo
2021-07-13 08:28:06 -04:00
ee3814dbfd
ARTEMIS-3383 AMQPMessage.isDurable wrongly returns false during persistent lazy reload state
2021-07-12 23:00:16 -04:00
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
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
7fc312ab5d
ARTEMIS-3372 - disconnect consumers on queue deletion event
2021-07-06 16:16:33 -04:00
b7f9807cd9
ARTEMIS-2919 support timestamping incoming messages
2021-07-06 14:09:00 -05:00
1d02d06eab
ARTEMIS-3374 config-managed queue can be deleted by durable subscriber
2021-07-06 14:06:39 -05:00
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
bafefdc8ec
ARTEMIS-3338 Preserve prepared XA transactions on connection failure
2021-06-09 15:00:45 -04:00
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
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
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
cdaa00d470
ARTEMIS-3317 OpenWire property conversion can cause ClassCastException
2021-05-27 09:52:49 -04:00
6ec7a69d45
ARTEMIS-3236 Preserve managed queues on removing MQTT subscription
2021-05-25 11:24:53 -05:00
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
a34d9aad6b
ARTEMIS-3295 - do not cluster advisories
...
https://issues.apache.org/jira/browse/ARTEMIS-3295
2021-05-14 10:08:21 -04:00
0f3d87799a
ARTEMIS-3240 - ensure pending transactions are rolled back on connection failure. Fix and test
2021-04-16 10:22:06 -04:00
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
d408f284b1
ARTEMIS-3238 AMQP Mirror not routing correctly with SNF
2021-04-12 19:30:35 -04:00
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
b4789a894f
ARTEMIS-3221 Migrating to Jakarta EE 8 artifacts
2021-04-09 11:49:59 -04:00
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
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
8fd1b33d16
ARTEMIS-3197 - add selectorAware option to virtualTopicConsumerWildcards for openwire acceptor
2021-03-22 19:15:02 -04:00
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
e1669d4ad2
ARTEMIS-3172 don't log STOMP CONNECT passcode header
2021-03-17 09:53:22 -05:00
96a09041ee
ARTEMIS-3183: resolve various immediate warnings at build start
...
- Remove duplicates dependency definition following e7e3c71511
2021-03-16 12:48:48 +00:00
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
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
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
12c8096a23
ARTEMIS-3093 Ordering on multiple consumers and core with rollback
2021-02-22 15:10:04 -05:00
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
7d10e915b6
ARTEMIS-3116 Fixing Core->AMQP Conversion of Scheduled Delivery Time
2021-02-12 13:00:06 -05:00
21ee5985ea
[maven-release-plugin] prepare for next development iteration
2021-02-11 12:00:04 -05:00
36a771150b
[maven-release-plugin] prepare release 2.17.0
2021-02-11 11:59:51 -05:00
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
7f64822591
Revert "[ARTEMIS-3113]: Artemis AMQP shouldn't depend on JMS."
...
This reverts commit 5079ad1019
2021-02-10 18:34:25 -05:00
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
c0867f0361
[maven-release-plugin] prepare for next development iteration
2021-02-09 12:12:48 -05:00
9b473698e0
[maven-release-plugin] prepare release 2.17.0
2021-02-09 12:12:35 -05:00
6ed1e4c87d
[maven-release-plugin] prepare for next development iteration
2021-02-08 15:56:31 -05:00
06b29806ca
[maven-release-plugin] prepare release 2.17.0
2021-02-08 15:56:18 -05:00
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
267c6e5b56
ARTEMIS-3091 Fix AMQP message headers export from the journal
2021-02-01 11:54:37 -05:00
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
9d070812dd
ARTEMIS-3079 Fix AMQP binary properties serialization to JSON
2021-01-25 13:22:53 -06:00
78c0792989
ARTEMIS-3065 AMQP Anonymous producer would eventually block
2021-01-13 15:46:54 -05:00
2e0f051d2d
ARTEMIS-3063 AMQPMessage get property can use a String switch
2021-01-12 12:07:23 +01:00
dc68d2e08f
ARTEMIS-3061 AMQPMessage::getDuplicateProperty can save key comparisons and class checks
2021-01-11 21:42:54 -05:00
be3812b2e2
ARTEMIS-3059 AMQP message reencoding should save creating Netty heap arenas
2021-01-11 11:37:30 -05:00
92d6ae87ed
ARTEMIS-3027 Fixing AMQP persister encoding
2020-12-22 10:37:34 -05:00
57c9dc623c
ARTEMIS-3035 Log.info on connection success for AMQP Broker Connection
2020-12-16 13:41:32 -05:00
3b0fa74970
ARTEMIS-3027 Fixing tests after some large messages changes
2020-12-14 15:19:12 -05:00
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
dfd41d958e
ARTEMIS-3027 Store calculated expiration as part of the journal record on AMQP
2020-12-10 18:33:15 -05:00
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
825341734a
ARTEMIS-3024 Expiry or DLQ Retry not working with AMQP
2020-12-08 14:13:53 -05:00
6a6a3b3863
ARTEMIS-3023 Avoid opening AMQP Large Message for final parsing
2020-12-07 21:24:45 -05:00
e6a6e81b02
ARTEMIS-3019 expiry changes in AMQP Large Message
2020-12-07 10:44:51 -05:00
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
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
9675ecae42
ARTEMIS-2985 - don't block netty threads for mqtt protocol actions
2020-11-12 21:01:00 +00:00
ead05b7a89
ARTEMIS-2983 Fixing PrintData with AMQP
2020-11-11 12:47:02 -05:00
14ec3cb7b0
ARTEMIS-2976 Remove password before creating server locator
2020-11-05 11:39:35 -05:00
5ff075b7ff
ARTEMIS-2971: add ANONYMOUS and EXTERNAL SASL mechanism support for outgoing AMQP server connections
2020-11-05 11:32:35 -05:00
4e7bb97df7
[maven-release-plugin] prepare for next development iteration
2020-11-02 17:45:51 -05:00
9768017530
[maven-release-plugin] prepare release 2.16.0
2020-11-02 17:45:38 -05:00
648340a864
ARTEMIS-2969 / ARTEMIS-2937 Making sure consumers are cleaned after failures and reconnects
2020-11-02 17:24:45 -05:00
7a435a944c
ARTEMIS-2969 / ARTEMIS-2937 should set connecting = false when maxRetry is reached
2020-11-02 13:13:15 -05:00
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
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
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
28919b6ad8
[maven-release-plugin] prepare for next development iteration
2020-10-30 10:16:29 -04:00
af5ca9f1e6
[maven-release-plugin] prepare release 2.16.0
2020-10-30 10:16:17 -04:00
f3dde91b91
ARTEMIS-2969 / ARTEMIS-2937 Dealing with instant disconnects on amqp broker connections
2020-10-30 09:52:03 -04:00
dff2ed3638
ARTEMIS-2937 Implementing skip create and skip delete on Mirror Source
2020-10-30 08:44:51 -04:00
981b516479
ARTEMIS-2968 Ignoring expected exception when deleting a previously already removed queue
2020-10-29 22:04:33 -04:00
480197975b
ARTEMIS-2967 Adding testSimpleConnect back and fixing a possible NPE
2020-10-29 22:01:01 -04:00
9b0f7605cb
ARTEMIS-2969 / ARTEMIS-2937 Dealing with Connection Timeout properly on AMQP Broker Connections
2020-10-29 21:55:10 -04:00
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
d51c89471e
ARTEMIS-2966 Anycast queues with distinct names would cause issues on sending messages
2020-10-29 10:09:36 -04:00
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
bf52134dc0
ARTEMIS-2937 Fixing Tests and some review
2020-10-28 15:08:48 -04:00
8499eac76c
ARTEMIS-2937 Server Side AMQP Connectivity with options to transfer queues or replicate data
2020-10-28 11:37:25 -04:00
cdc283fba5
ARTEMIS-2915 duplicate temp queues using OpenWire
2020-09-24 12:48:36 -04:00
feca90d475
ARTEMIS-2766 Fixing unused stopSet parameter
2020-09-23 15:52:52 -04:00
6a4e79fd06
ARTEMIS-2910: reuse routing type calculated in initialisation for fixed-address producers
2020-09-23 12:09:18 -04:00
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
e47eb5ae20
ARTEMIS-589 flow control for individual STOMP subscribers
2020-09-16 10:13:47 -04:00
7cf5289efa
ARTEMIS-2900 Expose property (getWholeMessageSize) so users can intercept size of messages and large messages
2020-09-14 15:35:46 -04:00
4d45d0cdd2
ARTEMIS-2887 Adding toString back to AMQPMessage
2020-08-26 17:54:25 -04:00
32bf9680f2
[maven-release-plugin] prepare for next development iteration
2020-08-24 16:03:24 +02:00
a549fcedde
[maven-release-plugin] prepare release 2.15.0
2020-08-24 16:03:12 +02:00
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
70068a0659
ARTEMIS-2844 Save additional copies and use pooled direct ByteBufs
2020-07-30 23:32:10 -04:00
0db13ee8ab
ARTEMIS-2844 Use writeAndFlush with voidPromise to reduce GC pressure
2020-07-30 23:32:10 -04:00
18b8df0f09
ARTEMIS-2855 Define a new broker plugin to track XA transactions
2020-07-29 10:40:55 -04:00
6690ba1d24
[maven-release-plugin] prepare for next development iteration
2020-07-09 12:49:08 -04:00
a76f41a7ed
[maven-release-plugin] prepare release 2.14.0
2020-07-09 12:48:54 -04:00
c1be566c20
NO-JIRA Fixing rare intermittent failure on CreditsSemaphoreTest
2020-07-08 12:36:26 -04:00
20daf2354c
ARTEMIS-2817 Support Stomp subscription with FQQN+multicast
2020-07-07 08:21:22 -04:00
4e40b42521
ARTEMIS-2809 retain api used by activemq-cli-tools
2020-06-17 15:20:57 +01:00
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
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
e1d8f42cc1
ARTEMIS-2798 expiration for AMQP msgs not reloaded
2020-06-09 15:18:45 -04:00
56dbd91263
ARTEMIS-2788 clear openwire producer exchange, created on send, on producer close event
2020-06-05 10:22:44 +01:00
111b551d79
ARTEMIS-2789 AMQP Large Message Memory Estimate
2020-06-03 23:23:16 -04:00
1a5b1fbe8e
ARTEMIS-2788 clear openwire producer state on produce close event
2020-06-03 13:33:18 +01:00
faa83b2ba6
[maven-release-plugin] prepare for next development iteration
2020-05-16 18:38:47 -04:00
5f49d89264
[maven-release-plugin] prepare release 2.13.0
2020-05-16 18:38:34 -04:00
1420ad7745
ARTEMIS-2766 Improving AMQPMessageSymbolSearch for correctness
2020-05-16 11:39:21 -04:00
83c7942a78
ARTEMIS-2766 Fixing AMQP Large Messages after Parsing change
2020-05-15 17:57:00 -04:00
c99fcd501b
[maven-release-plugin] prepare for next development iteration
2020-05-15 16:42:54 -04:00
47fafac760
[maven-release-plugin] prepare release 2.13.0
2020-05-15 16:42:41 -04:00
8562e6a1a7
ARTEMIS-2766 Not parsing application properties for duplicate property
2020-05-15 16:17:15 -04:00
9ff3c17525
ARTEMIS-2757 improving flow control in AMQP
2020-05-15 16:12:07 -04:00
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
9571ca16db
ARTEMIS-2753 Expanding wildcard fix to Advisories
2020-05-07 12:16:35 -04:00
c20d894e81
ARTEMIS-2753 Fixing OpenWire Temporary queue names over wildcard configurations
2020-05-06 23:24:24 -04:00
7438d7ff07
ARTEMIS-2750 Fixing out of order cancellations in AMQP
2020-05-04 13:15:56 -04:00
8a04ee07de
ARTEMIS-2648 - audit logging improvements
...
https://issues.apache.org/jira/browse/ARTEMIS-2648
2020-05-04 15:19:08 +01:00
ede2051960
ARTEMIS-2655 support auto-creation w/FQQN & STOMP
2020-05-01 13:40:24 -05:00
6709883d0e
ARTEMIS-2738 implement per-acceptor security domains
2020-04-28 21:45:38 -04:00
2ebf3c8e1b
ARTEMIS-2372 Filtering on Message Annotations
2020-04-28 11:18:30 -04:00
11a3e810bb
[maven-release-plugin] prepare for next development iteration
2020-04-21 17:06:21 -04:00
30272e0c2f
[maven-release-plugin] prepare release 2.12.0
2020-04-21 17:06:08 -04:00
974609d206
ARTEMIS-2728 Fixing Deadlock with LargeServerMessage
...
verified by LargeMessageTest::testTwoBindingsAndRestart
2020-04-20 14:40:46 -04:00
d231e2ac63
[maven-release-plugin] prepare for next development iteration
2020-04-16 16:16:41 -04:00
9636f4a3b0
[maven-release-plugin] prepare release 2.12.0
2020-04-16 16:16:28 -04:00
ad60a0b02b
ARTEMIS-1975 Dealing with connection drops on AMQP Large Message
2020-04-15 22:26:58 -04:00
87eebc3d27
ARTEMIS-2712 Dealing with Aborts AMQP Large Message
2020-04-15 22:21:11 -04:00
e7a437d999
ARTEMIS-2706 Discounting Transfer payload size
2020-04-14 16:56:52 -04:00
d27d61f223
ARTEMIS-2706 Use FrameSize to decide when to flush large messages
2020-04-14 12:59:25 -04:00
fc6402613d
ARTEMIS-2664 Simplify the credits acquiring.
...
Replace the AtomicInteger with an int. Indeed deliveredAcks is used only by
the acknowledge method and it is only executed by the EpollEventLoop thread
bounded with the relative connection channel.
2020-04-13 16:48:57 -04:00
89f58e1597
ARTEMIS-2695 Return exception message in AMQP conversion error response
2020-04-13 16:03:42 -04:00
2efa44daf5
ARTEMIS-2692 refactor queue creation
...
This commit does the following:
- Deprecates existing overloaded createQueue, createSharedQueue,
createTemporaryQueue, & updateQueue methods for ClientSession,
ServerSession, ActiveMQServer, & ActiveMQServerControl where
applicable.
- Deprecates QueueAttributes, QueueConfig, & CoreQueueConfiguration.
- Deprecates existing overloaded constructors for QueueImpl.
- Implements QueueConfiguration with JavaDoc to be the single,
centralized configuration object for both client-side and broker-side
queue creation including methods to convert to & from JSON for use in
the management API.
- Implements new createQueue, createSharedQueue & updateQueue methods
with JavaDoc for ClientSession, ServerSession, ActiveMQServer, &
ActiveMQServerControl as well as a new constructor for QueueImpl all
using the new QueueConfiguration object.
- Changes all internal broker code to use the new methods.
2020-04-13 14:25:30 -05:00
c36170477d
ARTEMIS-2686 Fix MQTT connect message rejection
...
Initialize the session state with a default value to fix a NPE, when an incoming
MQTT interceptor rejects a MqttConnectMessage.
2020-04-08 15:45:19 -04:00
858a8240f9
ARTEMIS-2659 / ARTEMIS-2673 Fix AmqpSendReceiveTest.testAcceptWithoutSettling
2020-04-07 23:06:40 -04:00
af796d5ce4
ARTEMIS-2701 Improving DLQ/check over previously removed records
2020-04-06 12:25:35 -04:00
bd77a536c6
ARTEMIS-2685 Not Block Netty Thread in any way for OpenWire
2020-04-01 18:02:48 -04:00
8cf35385a4
ARTEMIS-2608 Fix ClassCastException on binary properties conversion
2020-03-27 13:12:57 -04:00
ca50b3449e
ARTEMIS-1975 Removing ThreadLocal for StorageManager
2020-03-25 21:54:46 -04:00
03fb630f73
ARTEMIS-1975 Fixing LargeMessage encoding for replication
2020-03-25 16:16:05 -04:00
b9fa8b96ec
NO-JIRA fix failing MQTT test
...
I've seen o.a.a.a.c.p.m.MQTTRetainMessageManagerTest fail a handful of
times recently in PR builds. This change fixes that failure.
2020-03-25 11:11:52 -05:00
a4489a322e
ARTEMIS-1975 Moving encode cache towards AMQPLargeMessage
...
Using a property on AMQPLargeMessage instead of a ThreadLocal
This was causing issues on the journal as the message may transverse different threads on the journal.
2020-03-24 18:22:59 -04:00
f874a02d17
ARTEMIS-2673 PageStore should only be removed when Address is removed
...
& ARTEMIS-2674 AMQP should use a separate executor for IO
2020-03-23 20:02:17 -04:00
085a74cf06
ARTEMIS-2669 not durable AMQP messages cannot became durable on depaging
2020-03-22 17:46:37 -04:00
559fa2008d
ARTEMIS-2672 multi-thread isue with Shared Subscriptions
...
Some of them may throw queue already existed exception
2020-03-20 21:26:45 -04:00
f1fdfc6857
ARTEMIS-2665 AMQP use createSharedQueue like Core
2020-03-18 11:51:58 -04:00
a5bd0065a9
ARTEMIS-2617 Fixing KMPNeedle::searchInto API and specializing it
...
KMPNeedle::searchInto has been specialized and copied
to handle ReadableBuffer in order to save polymorphic
calls on it that would make it slower on hot paths.
2020-03-17 16:30:12 -04:00
43639bdeae
ARTEMIS-2664 The prefetch size is exceeded after delivered acks
...
Decrement delivered acks before acquiring credits.
2020-03-17 14:08:10 -04:00
5f0b7dd7cd
ARTEMIS-2661 AMQP Journal loading is triggering reencode
2020-03-17 14:02:28 -04:00
2105479304
ARTEMIS-2658 AMQP message read from page has wrong encode size
2020-03-16 18:20:39 +01:00
d15b3aeed6
ARTEMIS-2650 OpenWire Browsing is not sending credits
2020-03-16 09:12:12 -04:00
4d2b6c07bd
NO-JIRA just adding AMQPPersisterTest
2020-03-13 15:07:37 -04:00
c3128aa144
ARTEMIS-2642 Fixing Drain Timeout Issue on AMQP
...
The drain control has to immediately flush
otherwise a next flow control event may remove the previous status from Proton.
So, this really cannot wait the next executor, and it has to be done immediately.
2020-03-11 11:44:42 -04:00
aa8d598a35
ARTEMIS-2650 The delivering count is wrong after reconnecting an openwire client
...
Fix the conversion of the message id from the CORE messages.
Fix the credits acquired for acknowledges related to undelivered messages.
2020-03-11 11:14:29 -04:00
2ce8f01911
ARTEMIS-2476: implemented MQTTRetainMessageManagerTest
2020-03-07 21:15:57 +00:00
e608c9af2c
fix for #ARTEMIS-2476
2020-03-07 21:15:57 +00:00
a9e6dbb0e3
NO-JIRA reconcile STOMP prop names b/w code & doc
2020-03-05 20:49:25 -06:00
e9ee9956bd
ARTEMIS-2639 lost notif props with OpenWire+divert
...
Historically speaking, all message properties starting with AMQ HDR
would not be passed to OpenWire messages. However, that blocked the
properties from management notifications so ARTEMIS-1209 was raised and
the solution there was to pass properties that started with _AMQ *if*
the consumer was connected to the management notification address.
However, in this case messages are diverted to a different address so
this check fails and the properties are removed. My solution will be to
check the message itself to see if it has the _AMQ_NotifType property
(which all notification messages do) rather than checking where the
consumer is connected.
2020-03-05 21:38:51 -05:00
c0f3ea66a9
ARTEMIS-2641 Openwire client runs out of credits after reconnection
...
Clear the messagePullHandler on setting prefetchSize.
2020-03-04 09:14:53 +01:00
ddd8ed4402
ARTEMIS-1975 Real Large Message support into AMQP
...
This is a Large commit where I am refactoring largeMessage Body out of CoreMessage
which is now reused with AMQP.
I had also to fix Reference Counting to fix how Large Messages are Acked
And I also had to make sure Large Messages are transversing correctly when in cluster.
2020-02-25 15:25:01 +01:00
a8cf6b04b4
ARTEMIS-2607 interceptor returns false but processing continues
2020-02-14 13:23:05 -05:00
daae7e750a
ARTEMIS-2619 allow disabling STOMP 'server' header
2020-02-12 19:38:38 -06:00
d42267f05a
ARTEMIS-2617 Lazy scan AMQP message data
2020-02-12 13:29:51 -05:00
5897909dc9
ARTEMIS-2617 use core pools to reduce GC on journal loading
2020-02-12 13:29:51 -05:00
26b5ad439c
NO-JIRA Remove redundant instanceof check in CoreAmqpConverter
...
message is of type ServerJMSMessage, thus the test `if (message instanceof ServerJMSMessage)` always yields true.
2020-02-03 09:56:39 -06:00
1716655214
ARTEMIS-2597 Memory Leak when closing AMQP Consumers in the context
...
Remove server senders on remote link close.
2020-01-15 09:56:21 +01:00
97735ca72c
[maven-release-plugin] prepare for next development iteration
2020-01-10 09:00:58 -06:00
25a947f6cb
[maven-release-plugin] prepare release 2.11.0
2020-01-10 08:57:46 -06:00
39cd9d56f6
ARTEMIS-2497: [AMQP] Allow handling of the reject disposition to be configured.
2020-01-08 11:56:23 -05:00
13278cc45f
ARTEMIS-2581 Duplicate Detection on AMQP should be configurable
...
There is an optimization in AMQP, that properties are only parsed over demand.
It happens that after ARTEMIS-2294 (commit 2dd0671698
2019-12-19 17:54:21 -05:00
eeaeba6354
ARTEMIS-2557 don't export openwire-protocol JMS spec dep
2019-12-16 14:29:32 -05:00
7bd710520d
ARTEMIS-2494: [AMQP] Allow Modified disposition to be used signal address full to a sending peer
2019-12-03 11:05:23 -05:00
044319da05
ARTEMIS-2560 Duplicate amqp messages over cluster
...
When AMQPMessages are redistributed from one node to
another, the internal property of message is not
cleaned up and this causes a message to be routed
to a same queue more than once, causing duplicated
messages.
2019-12-03 09:46:28 -05:00
d02da18dab
ARTEMIS-2506 MQTT doesn't cleanup underlying connection for bad clients
...
When a bad MQTT clients drop its connection without proper closing
it the broker doesn't close the underlying physical connection.
2019-09-27 19:41:15 +08:00
91f4d0a633
[maven-release-plugin] prepare for next development iteration
2019-09-23 11:19:54 -04:00
86a975fdad
[maven-release-plugin] prepare release 2.10.1
2019-09-23 11:19:42 -04:00
2ec96bf46d
ARTEMIS-2488: Handle the case where source address is null
2019-09-18 20:49:16 -04:00
05a93314cd
ARTEMIS-2493 OpenWire session close doesn't cleanup consumer refs
...
When an openwire client closes the session, the broker doesn't
clean up its server consumer references even though the core
consumers are closed. This results a leak when sessions within
a connection are created and closed when the connection keeps open.
2019-09-17 09:44:25 +08:00
7263e820f3
NO-JIRA Fixing intermittent failure on CreditsSemaphoreTest
2019-09-05 15:41:33 -04:00
5016f69daa
[maven-release-plugin] prepare for next development iteration
2019-08-26 10:42:13 -04:00
f092d5396a
[maven-release-plugin] prepare release 2.10.0
2019-08-26 10:42:01 -04:00
c929d34eed
ARTEMIS-2454 Fixing body re-encoding
2019-08-25 23:03:53 -04:00
25d0b511ce
ARTEMIS-2458 Fix AMQP Transaction Session Close Ordering
2019-08-21 09:34:08 -04:00
61eb379741
ARTEMIS-2458 Fix AMQP Transaction Rollback Ordering by using a sorted add
2019-08-21 09:34:07 -04:00
448f72738b
ARTEMIS-2437 Allow extended types in annotations in AMQP to Core
...
When converting from AMQP to core and back again support annotations that
aren't able to be placed into Core message properties by storing the bytes
from encoding the types to AMQP encodings and then decoding them again
when converting back into AMQP messages.
Requires update to proton-j 0.33.2 for encoding fix
2019-08-18 22:13:35 -04:00
5f75f68129
ARTEMIS-2454 Message Body damaged after re-encoding
2019-08-18 17:17:12 -04:00
f303cd7ca9
NO-JIRA Adding log.warn on AMQPMessage
2019-08-09 14:05:41 -04:00
205a1399e7
ARTEMIS-2440 Call timeout should retry the connection asynchronously
2019-08-05 12:12:33 -04:00
cd723aa528
ARTEMIS-2440 Connection.fail on sendBlock should be asynchronous
...
This is following up on ARTEMIS-2327.
2019-08-02 16:37:12 -04:00
edace8845e
ARTEMIS-2414 Sync before closing file in case data loss
2019-07-29 14:44:26 -04:00
8a1f267bd5
Revert "ARTEMIS-2423 Improving Consumer/Queue Delivery lock"
...
This reverts commit 7507a9fd4b
2019-07-27 10:45:08 -04:00
7507a9fd4b
ARTEMIS-2423 Improving Consumer/Queue Delivery lock
2019-07-26 15:05:51 -04:00
022b5895ef
ARTEMIS-2394 Improve scheduling sync for AMQPConnectionContext
...
Remove synchronized blocks using an AtomicReference.
2019-07-22 10:55:18 -04:00
8484c8a43b
ARTEMIS-2389 add details to conn failure logging
2019-07-22 09:56:55 -04:00
1c45d1758d
ARTEMIS-2409 Convert HornetQ field names in consumer/queue selector strings
2019-07-17 11:34:04 -04:00
c66d62e4b0
ARTEMIS-2390 JMSMessageID header can be null when messages are cross-protocol
...
If a jms client (be it openwire, amqp, or core jms) receives a message that
is from a different protocol, the JMSMessageID maybe null when the
jms client expects it.
2019-06-27 10:26:34 -04:00
d14c0de335
ARTEMIS-2385 Log header for rejecting message with too large header
...
Fix test and warning condition to avoid false issues.
2019-06-20 16:20:11 +02:00
74c79625b8
ARTEMIS-2002 Proton transport objects leaked
...
Remove scheduled tasks when a client disconnects to allow garbage
collector to delete the unused proton objects. Add a the unity test
AMQPConnectionContextTest to check leaks after close.
2019-06-19 10:38:00 -05:00
6a2e964f5b
ARTEMIS-2386 - use internal session for management queues for QOS2
...
https://issues.apache.org/jira/browse/ARTEMIS-2386
2019-06-18 08:21:39 +01:00
d1add00b00
ARTEMIS-2378 respect openwire removeInfo lastSequenceId when dealing with delivery count
2019-06-17 22:32:33 -04:00
dbb2b54fa7
[maven-release-plugin] prepare for next development iteration
2019-05-29 22:02:00 -05:00
88c686cc99
[maven-release-plugin] prepare release 2.9.0
2019-05-29 21:59:18 -05:00
b8a2580410
ARTEMIS-2360 IOOBE when dealing with older clients concurrently
2019-05-29 15:02:13 -04:00
500aa09360
NO-JIRA Improving HornetQInterceptor test with modifications
2019-05-23 12:49:41 -04:00
e533bf876e
ARTEMIS-2344 return security errors for unauthorized anonymous sasl
...
When user attempts unauthorized anonymous sasl the broker can return an
error of 'failed' instead of the security error that is expected in
these cases.
2019-05-17 15:52:37 -04:00
2ae732cfc8
[maven-release-plugin] prepare for next development iteration
2019-05-16 09:58:27 -04:00
481b9824a8
[maven-release-plugin] prepare release 2.8.1
2019-05-16 09:58:15 -04:00
7f7194f779
ARTEMIS-2333 Making tests more reliable
2019-05-08 21:10:05 -04:00
408cd3745c
ARTEMIS-2333 Applying proper fix on Stomp delivery
...
When connection is dead, the StompSession may deliver a message and if AUTO-ACK it would ack and lose the message
2019-05-08 18:16:23 -04:00
ee7d5bd0f1
ARTEMIS-2319 Upgrading jboss-logging dependencies
...
* Upgrading versions
* Adding wildfly-common dependency as jboss-logmanager now depends on it
for simple common operations such as getting hostname or process id
* Updating bootclasspath with wildfly-common
2019-05-07 16:13:48 -04:00
0e40984145
NO-JIRA speeding up a few tests
2019-05-06 20:22:47 -04:00
6f0380097e
ARTEMIS-2330 Fixing Possible NPE on HQPropertiesConversionInterceptor
2019-05-02 19:20:40 -04:00
56152a9e7c
[maven-release-plugin] prepare for next development iteration
2019-05-02 16:39:10 -04:00
a8e7f9d07a
[maven-release-plugin] prepare release 2.8.0
2019-05-02 16:38:58 -04:00
f584efd574
ARTEMIS-2326 remove pwd params before creating protocol mgr
2019-04-29 20:53:15 -04:00
f508a25566
ARTEMIS-2320 Standard Charset object can be used
2019-04-29 11:28:10 +01:00
228f6af4ca
[maven-release-plugin] prepare for next development iteration
2019-04-25 16:52:09 -04:00
09d2ba18a7
[maven-release-plugin] prepare release 2.8.0
2019-04-25 16:51:57 -04:00
e0815438d5
ARTEMIS-2316 Reverting change on AMQPMessage, and changing test to be accurate
...
This (kind of) reverts commit bd1162d9b8
2019-04-25 11:23:43 -04:00
15a335df01
ARTEMIS-2318 HornetQ Protocol Manager should copy the messages before replacing message properties
2019-04-24 16:27:32 -04:00
bd1162d9b8
ARTEMIS-2316 AMQPMessage missing ApplicationProperties from custom transformer
2019-04-23 21:57:21 +01:00
1e35175a4d
ARTEMIS-2311 Dealing with Protocol conversions and JMSReplyTo
2019-04-22 21:45:24 -04:00
da4f95cf71
ARTEMIS-2305 ACK counters to only increment after commit
...
Also including a new metric for ack attempts that will keep the former semantic.
2019-04-12 14:34:51 -04:00
Robbie Gemmell
Domenico Francesco Bruscino
Clebert Suconic
franz1981
gtully
Justin Bertram
Andy Taylor
Christoph Läubrich
岳豹
brusdev
Emmanuel Hugonnet
Dirkjan Ochtman
Federico Valeri
Michael Pearce
Assen Sharlandjiev
Sebastian Thomschke
Keith Wall
Howard Gao
Ulf Lilleengen
Timothy Bish
Wei Yang
Tomas Hofman
Emmanuel Hugonnet
Jiri Danek
Luis De Bello