Commit Graph

392 Commits

Author SHA1 Message Date
JB Onofré fd7f483997
Merge pull request #1324 from Nikita-Shupletsov/kahadb_topic_fix
[AMQ-9595] Fix recoverNextMessages when there are messages consumed farther than maxBatchSize.
2024-10-23 15:48:26 +02:00
Nikita Shupletsov 6b08e10420 [AMQ-9595] Fix recoverNextMessages when there are messages consumed farther than maxBatchSize. 2024-10-18 15:26:32 -07:00
Aleksei Zotov 736eb467e1 AMQ-8122 - Fix DataByteArrayInputStreamTest 2024-09-11 17:09:36 -04:00
Christopher L. Shannon 5f79b651c2 AMQ-9547 - Remove setLength() and usage from RecoverableRandomAccessFile
This method always throws an exception so it should be removed and no
longer used. Places in PageFile that called the method have been updated
to either remove the usage or throw an error.
2024-08-08 12:29:35 -04:00
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
PascalSchumacher 3b450d9778 KahaDBStore: Fix typo in comment and remove duplicate semicolon 2024-06-24 19:39:58 +02: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
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
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
Shikhar Gupta f8bbeeee22 AMQ-9166: Add destination to scheduler job 2024-03-02 13:56:55 +01: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) a0b8a1fe55 revert unnecessary change 2024-01-23 10:19:04 -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
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
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 5f72c35b3b [AMQ-9310] Remove solaris support 2023-09-28 18:00:55 -05:00
JB Onofré d5ea415463 Set version to 6.0.0-SNAPSHOT 2023-09-15 16:27:34 +02:00
Matt Pavlovich 976db65c58 [AMQ-9239] jakarta.jms - activemq-kahadb-store changes 2023-08-24 09:45:31 -05:00
sigee 3ba93ed957 Remove unnecessary boxing / unboxing 2023-07-23 12:08:23 +02:00
Matt Pavlovich cfbea60d6d
[AMQ-9258] Update kahadb corruption test to account for new fix from AMQ-9254 (#1007) 2023-05-18 11:29:01 -05:00
Matt Pavlovich 0a042964c8
[AMQ-9258] Add NPE guards to kahadb test that intermittently fails on slower CI servers (#1006) 2023-05-17 10:27:31 -05:00
Christopher L. Shannon (cshannon) bcc74f93fe AMQ-9254 - Rework data file size validation and add unit test
This isolates the validation on data file length on read and adds unit
tests to verify we properly fallback to the real file length on initial
size check failure
2023-05-03 06:03:00 -04:00
Matt Pavlovich 3e61a200d0 [#9254] DataFile readRecord fallback to OS file.length in rare edge case 2023-05-01 20:09:22 -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é 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 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
JB Onofré c86cd20029
Merge pull request #957 from mjanczykowski/bugfix/AMQ-9199
[AMQ-9199] Fixed race condition in creating store directory
2023-02-02 14:43:40 +01:00
Christopher L. Shannon (cshannon) ed924cddac AMQ-9202 - Make sure Reentrant locks are acquired outside a try block
This is best practice and will prevent unlock from being attempted
inside of a finally block when the thread doesn't actually own the
lock which can happen when the lock attempt throws an exception
such as calling lockInterruptibly()
2023-02-01 11:19:24 -05:00
Michał Janczykowski 13ec5d5b7a [AMQ-9199] reordered imports 2023-01-17 12:26:21 +01:00
Michał Janczykowski 7de7ba2aa9 [AMQ-9199] Fixed race condition in creating store directory
A store directory is created by MessageDatabase#getPageFile which
is called in two cases:
1. KahaDBStore.start() when creating a queue
2. KahaDBStore.size() which is performed when sending any persistent message

If both methods are called concurrently it's possible to get an IOException
thrown from the IOHelper.mkdirs method.
2023-01-17 12:20:53 +01:00
Dmytro Chebotarskyi dc55028c00 Added additional logging on BrokerService startup 2022-11-29 07:51:20 +01:00
Dmytro Chebotarskyi 73f827f9a6 [NO JIRA] Removing unused concurrentStoreAndDispatchTransactions variable from KahaDBStore. Cleaning up related unused code. 2022-09-06 12:18:40 -07:00
Lucas Tétreault e550748b4c [AMQ-9005] remove xalan dependency due to it being end of life 2022-07-30 22:45:48 -07:00
Christopher L. Shannon (cshannon) 3d06efe93d AMQ-8530 - Update to geronimo-annotation_1.3_spec 2022-03-09 08:14:43 -05:00
Christopher L. Shannon (cshannon) 00253b3219 NO-JIRA: Updating next development version to 5.18.0-SNAPSHOT 2022-03-01 09:36:34 -05:00