Commit Graph

1319 Commits

Author SHA1 Message Date
Matt Pavlovich dad947fe4a [AMQ-9484] Support exporting kahadb messages from a queue with an offset
(cherry picked from commit 1a1b42f0c9)
2024-07-16 08:08:26 -05:00
Matt Pavlovich c465330be5 [AMQ-9455] DestinationPolicy support for MessageInterceptorStrategy 2024-06-13 12:52:32 -05:00
Christopher L. Shannon 527d245831 AMQ-9504 - Add missing license header 2024-05-22 10:11:24 -04:00
Christopher L. Shannon ddfb36515c AMQ-9504 - Prevent registering duplicate mKahadb adapters
This fixes an issue on start up of a broker that is configured with
multiple mKahaDB filtered adapters and one is configured with
perDestination=true. Before this fix a duplicate persistence adapter
could be created because the filter did not check for existing matches.

Patch applied with thanks to Ritesh Adval
2024-05-22 09:22:01 -04:00
Matt Pavlovich d0a435fe5b
Update main to 6.2.0-SNAPSHOT 2024-04-29 10:52:46 -05:00
JB Onofré 6084867b26 [maven-release-plugin] prepare for next development iteration 2024-04-11 19:41:29 +02:00
JB Onofré ceea6dac1c [maven-release-plugin] prepare release activemq-6.1.2 2024-04-11 19:41:18 +02:00
Christopher L. Shannon c8f0419fff AMQ-9475 - ConsumerControl commands should not auto create wildcard
dests

This fixes an issue where wildcard destinations could be inadvertently
created by ConsumerControl commands which could lead to problems. The
processing logic for this command now will only look up existing
destinations if they exist.
2024-04-10 11:53:12 -04:00
JB Onofré e025e443e6 [maven-release-plugin] prepare for next development iteration 2024-04-01 16:28:46 +02:00
JB Onofré 5690826111 [maven-release-plugin] prepare release activemq-6.1.1 2024-04-01 16:28:36 +02:00
Grzegorz Kochanski 4d40023968 AMQ-9452: unwrap BaseDestination to access queue/topic message
Change-Id: Ic05002ecb428e2aa5abeb9dc3e499e3aae550051
2024-03-15 12:31:14 +01:00
JB Onofré 72bbb0c521 [maven-release-plugin] prepare for next development iteration 2024-03-11 14:41:18 +01:00
JB Onofré 5af7c1f550 [maven-release-plugin] prepare release activemq-6.1.0 2024-03-11 14:41:08 +01:00
Jean-Baptiste Onofré 7fae1b98e7 AMQ-9419: Implement createContext(int sessionMode) method 2024-03-04 13:15:08 +01:00
Christopher L. Shannon 75de932116 AMQ-9436 - Ensure message audit in queue store cursor is shared
This commit fixes the initialization of the StoreQueueCursor message
audit object to make sure it's shared between the persistent and non
persistent cursors. It also adds a check to ensure that duplicate calls
to start will not try and init more than once.
2024-02-15 17:27:52 -05:00
Christopher L. Shannon 10d94bd165 AMQ-9435 - Ensure orderIndex next id is rolled back on duplicates
This commit fixes a bug in KahaDB that caused gaps in sequence ack
tracking for durables that would lead to the appearance of stuck
messages on durable subs if duplicate messages were detected. The
sequence is now correctly rolled back so that there is no gap if the
message is not added to the order index
2024-02-15 09:39:48 -05:00
Christopher L. Shannon (cshannon) f73cf2aaab AMQ-9420 - Don't decrement KahaDB durable sub metrics on duplicate ack
This adds a check in case a duplicate ack is passed to the store to make
sure that the subscription statistics (if enabled) for a durable sub do
not have the metrics decremented a second time
2024-01-23 10:02:19 -05:00
Matt Pavlovich 50baf95bff
[AMQ-9344] Add configurable limit to uncommitted transaction 2024-01-17 13:25:27 -06:00
JB Onofré 1747acaf03 Set version to 6.1.0-SNAPSHOT 2023-11-20 17:19:09 +01:00
JB Onofré dfd35d89f6 [maven-release-plugin] prepare for next development iteration 2023-11-14 08:13:24 +01:00
JB Onofré 14bac13f40 [maven-release-plugin] prepare release activemq-6.0.0 2023-11-14 08:13:14 +01:00
Jean-Baptiste Onofré 6172baff35 Cancel 6.0.0 release 2023-11-14 07:52:21 +01:00
JB Onofré 464efe0e6f [maven-release-plugin] prepare for next development iteration 2023-11-12 06:35:12 +01:00
JB Onofré 26b14ec994 [maven-release-plugin] prepare release activemq-6.0.0 2023-11-12 06:34:58 +01:00
Martin Devlin 573ae71ec9 AMQ-9187 - Queue Advisory message not sent
- a test case which demonstrates the bug.
  - the first test case sendDelayedMessage_usingNormalProducer works fine because it is using a normal named JMS MessageProducer. Included just for comparison purposes.
  - the 2nd test case sendDelayedMessage_usingAnonymousProducer shows the bug.
- the bug fix: swap the order of the AdvisoryBroker and SchedulerBroker BrokerFilters.
  - make AdvisoryBroker come after SchedulerBroker but before RegionBroker
  - this ensures that when a delayed message gets eventually forwarded to the RegionBroker, the RegionBroker will "see" the AdvisoryBroker when it invokes 'addDestination'. Thus, the AdvisoryBroker gets to send out the advisory message as expected.
2023-10-20 17:39:37 +02:00
JB Onofré dc4b584c7e
Merge pull request #237 from sigee/cleaning
Remove unnecessary boxing / unboxing
2023-10-19 16:03:52 +02:00
Christopher L. Shannon (cshannon) c3bef84be5 AMQ-9343 - Reduce memory used for in flight transactions
This commit will reduce the memory required in KahaDB for long running
transactions and transactions with a lot of pending message sends by
clearing out the message memory when no longer needed instead of keeping
it tracked in the pending map
2023-10-18 11:11:24 -04:00
Matt Pavlovich 578d86d726 [AMQ-9315] Add connectedTimestamp to Connection and JMX view 2023-10-03 09:09:48 -05:00
Matt Pavlovich 5f72c35b3b [AMQ-9310] Remove solaris support 2023-09-28 18:00:55 -05:00
Matt Pavlovich 09ae41adec [AMQ-8325] JMS 2.0 XA supported operations 2023-09-19 09:05:28 -05:00
JB Onofré d5ea415463 Set version to 6.0.0-SNAPSHOT 2023-09-15 16:27:34 +02:00
Matt Pavlovich 5243a4451c [AMQ-9239] jakarta.jms - activemq-unit-tests changes 2023-08-24 09:45:32 -05:00
Matt Pavlovich 65267a9a15 [AMQ-9239] jakarta.jms - activemq-unit-tests changes 2023-08-24 09:45:32 -05:00
sigee 3ba93ed957 Remove unnecessary boxing / unboxing 2023-07-23 12:08:23 +02:00
Christopher L. Shannon 901956d4dd
AMQ-9262 - Fix network subscriptions for composite consumers (#1014)
This fixes network subscriptions that are generated on demand when a
consumer uses composite destinations. Before this fix conduit
subscriptions didn't work correctly. This fix now splits up the
composite dest and generates correct demand for each of the individual
destinations.
2023-06-07 07:18:18 -04:00
Matt Pavlovich 67f5afa0f4 [AMQ-9259] Remove activemq-partition and zookeeper test dependency 2023-05-22 11:00:51 -05:00
Matt Pavlovich 9a5b61f6a2
[AMQ-9257] Disabled expire message checking when pauseDispatch=true (#1005) 2023-05-19 08:06:53 -05:00
Matt Pavlovich 6b277a4903
[AMQ-9239] Host joram jms unit tests ahead of converting to jakarta.jms (#1002)
Merging now for jakarta work, may backout later
2023-04-27 08:37:43 -05:00
Matt Pavlovich 5ca71dfee6
[AMQ-9234] Remove JournalJDBC store and activeio dependency (#993) 2023-03-29 08:38:25 -05:00
JB Onofré 6e5838d82d Move version to 5.19.0-SNAPSHOT 2023-03-28 16:11:10 +02:00
Jean-Baptiste Onofré 6edfdf7c17 [maven-release-plugin] prepare for next development iteration 2023-03-18 06:47:58 +01:00
Jean-Baptiste Onofré f18f3223fa [maven-release-plugin] prepare release activemq-5.18.0 2023-03-18 06:47:47 +01:00
JB Onofré e4fb4a2d4e
Merge pull request #986 from mattrpav/AMQ-9230
[AMQ-9230] Upgrade jmdns to 3.5.8 (new GAV)
2023-03-14 06:20:47 +01:00
Matt Pavlovich 413dfa9532
[AMQ-5137] make networkConnector decreaseNetworkConsumerPriority="true" the default (#771) 2023-03-13 20:00:36 -06:00
JB Onofré 030d1b5035
Merge pull request #981 from jbonofre/AMQ-9223
[AMQ-9223] Upgrade to slf4j 2.0.6
2023-03-11 07:28:32 +01:00
Matt Pavlovich 122b8f213a [AMQ-9230] Upgrade jmdns to 3.5.8 (new GAV) 2023-03-10 09:52:29 -06:00
Matt Pavlovich 642ec302cc
[AMQ-9225] Remove j2ee management dependency as it is no longer part of JEE spec (#983) 2023-03-07 11:13:41 -06:00
Jean-Baptiste Onofré 1e8de860ad [AMQ-9223] Upgrade to slf4j 2.0.6 2023-02-19 08:11:54 +01:00
Christopher L. Shannon 9fe24cd8e3
AMQ-7309 - Implement Message#isBodyAssignableTo and Message#getBody methods (#979)
AMQ-7309 - Implement Message#isBodyAssignableTo and Message#getBody
methods
2023-02-16 18:03:14 -05:00
Christopher L. Shannon (cshannon) ee14778305 AMQ-7309 - remove test after adding support for jms 2 create session 2023-02-15 18:05:17 -05:00