Matt Pavlovich
572414dbbc
[AMQ-9646] Support selecting specific messages for command line backup ( #1377 )
2025-02-08 09:13:19 -06:00
Christopher L. Shannon
d9e89f4b5f
AMQ-9658 - Properly increment transport receive counter ( #1389 )
...
Switch to using an AtomicInteger for tracking bytes received in a
TcpTransport. This makes incrementing the counter an atomic operation.
Previously a volatile int was used and incrementing volatiles is not
atomic because it's a 3 step process of read, update, set.
This also makes a small fix to ensure that the full initialization
buffer will always be entirely read and processed when using
the auto+nio+ssl transport. Previous the code assumed only the first
command was stored in the initialization buffer but technically more
bytes could exist for a future command (even if unlikely with the
current Java implementation).
2025-02-05 10:02:28 -05:00
Matt Pavlovich
7f8cf0e7d9
[AMQ-8463] New Feature: Advanced Message Flow statistics
...
Co-authored-by: Christopher L. Shannon <cshannon@apache.org>
2025-01-21 20:45:14 -06:00
DressedUpZebra
cb528078a6
[AMQ-9543] Replace use of deprecated setInactiveTimoutBeforeGC in unit tests ( #1269 )
...
* Fix typo in the deprication doc
* Replace use of depricated setInactiveTimoutBeforeGC
2024-12-18 18:15:52 -05:00
Matt Pavlovich
bb4c8aac66
[AMQ-9623] Update ConnectionView to include WireFormatInfo
2024-12-01 19:05:34 -06:00
Christopher L. Shannon
7f218fe05d
AMQ-9625 - Prevent queue messages from becoming stuck
...
Fixes a race condition bug that can lead to a message being missed on
dispatch and stuck on a Queue until restart when caching and
concurrentStoreAndDispatch are enabled on a Queue and the cache becomes
disabled.
2024-11-20 15:29:13 -05:00
Nikita Shupletsov
8399e66789
[AMQ-9530] Removed unused imports.
2024-11-08 15:06:06 -08:00
JB Onofré
be1856cace
Merge pull request #1247 from Nikita-Shupletsov/virtual_topic_fix
...
[AMQ-9530]Fix SelectorAwareVirtualTopicInterceptor ClassCastException if next is not Topic.
2024-11-08 11:09:15 +01:00
Nikita Shupletsov
473267baf8
[AMQ-9530] Fix SelectorAwareVirtualTopicInterceptor ClassCastException if next is not Topic.
2024-11-07 10:37:42 -08:00
Matt Pavlovich
7c81d73d8a
[AMQ-9563] Remove usage of java.security.AccessController where possible. Document JDK 21 refactor TODO
2024-09-25 10:46:56 -05:00
Matt Pavlovich
5910b94b09
[AMQ-9437] AdvancedDestination statistics networkEnqueue and networkDequeue counters
2024-09-20 08:56:26 -05:00
Aleksei Eraskin
2a5194a99b
for loop can be replaced with enhanced for
2024-07-19 17:30:12 -07:00
Matt Pavlovich
dad947fe4a
[AMQ-9484] Support exporting kahadb messages from a queue with an offset
...
(cherry picked from commit 1a1b42f0c9bd784b8c8aee4f42deab140d7480e3)
2024-07-16 08:08:26 -05:00
Aleksei Eraskin
d00cbe5b5c
for loop can be replaced with enhanced for
2024-07-12 16:44:09 -07:00
Matt Pavlovich
c465330be5
[AMQ-9455] DestinationPolicy support for MessageInterceptorStrategy
2024-06-13 12:52:32 -05:00
JB Onofré
986cd7c52b
Merge pull request #1219 from kenliao94/misc_fix
...
[Misc] Various misc. fixes for Broker interface
2024-05-03 08:30:37 +02:00
Ken Liao
9096ae6e75
Various muis fix for Broker interface
2024-05-02 16:26:23 -07: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
78d9555233
Merge pull request #1200 from cshannon/AMQ-9475
...
AMQ-9475 - ConsumerControl commands should not auto create wildcard dests
2024-04-11 06:55:34 -04: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
AM-19
d15dedf4e3
[AMQ-9470] Updated Methods to be called, to properly reload Log4j Properties
2024-04-02 21:14:28 +05:30
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
Matt Pavlovich
81e6b90ac8
[AMQ-9450] Expose Job Scheduler views with destination via JMX
2024-03-09 07:58:27 +01:00
JB Onofré
a2fa43359e
Merge pull request #1165 from jbonofre/AMQ-9431
...
AMQ-9431: Add org.apache.activemq.broker.BouncyCastleNotAdded system property to not load BouncyCastle in BrokerService
2024-03-03 17:02:25 +01:00
Shikhar Gupta
f8bbeeee22
AMQ-9166: Add destination to scheduler job
2024-03-02 13:56:55 +01:00
Jean-Baptiste Onofré
0a90f323ce
AMQ-9431: Add org.apache.activemq.broker.BouncyCastleNotAdded system property to not load BouncyCastle in BrokerService
2024-03-02 08:28:31 +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
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
JB Onofré
07cce0609b
Merge pull request #160 from emopers/SynchronizedCollection_140_422
...
TransportConnection does not synchronize iteration on synchronized list
2023-10-17 11:21:36 +02:00
JB Onofré
360a45488a
Merge pull request #1042 from PascalSchumacher/slow_consumer_log_message_superfluous_placeholder
...
AdvisoryBroker#handleFireFailure: Remove unused placeholder in warn l…
2023-10-15 08:09:13 +02:00
Matt Pavlovich
578d86d726
[AMQ-9315] Add connectedTimestamp to Connection and JMX view
2023-10-03 09:09:48 -05:00
Matt Pavlovich
9f374dfcb5
[AMQ-9301] Add additional fields to o.a.activemq.broker.jmx.Connection
2023-09-16 12:39:17 -05:00
JB Onofré
d5ea415463
Set version to 6.0.0-SNAPSHOT
2023-09-15 16:27:34 +02:00
Matt Pavlovich
fa7d1347e9
[AMQ-9239] jakarta.jms - activemq-broker changes
2023-08-24 09:45:31 -05:00
PascalSchumacher
97d4f3f6ad
AdvisoryBroker#handleFireFailure: Remove unused placeholder in warn log message. All information is already logged at warn level, so remove additional debug log message.
2023-08-24 08:08:16 +02:00
Matt Pavlovich
b751428ebb
[AMQ-9288] Fix TransportConnection logger to include exception message on Async Error ( #1038 )
2023-08-01 08:29:10 -05:00
