dac97e6294
[AMQ-7401] Make double-checked locking thread-safe by declaring the field volatile.
2020-02-10 19:06:17 +01:00
5a0c853ba0
AMQ-7353 - fix visibility of marshalledProperties to ensure competing threads don't see partial objects in error. Little test case that demonstrates the problem in isolation
2019-11-26 16:58:30 +00:00
b379879dbf
Stop failed timer task from breaking timers.
2019-11-23 15:00:23 +00:00
0c6f9a9a1e
AMQ-7352 - Add support for anonymous producer advisories
...
By default this behavior is turned off but can be enabled by setting
anonymousProducerAdvisorySupport on the BrokerService to true
2019-11-22 13:35:32 -05:00
a59ebe7d09
Merge pull request #283 from SaivR1t/master
...
AMQ-6963 Fix calling the toString() method in case of different log level.
2019-11-18 05:50:37 +01:00
057b950485
Merge pull request #322 from deeyes24/failing_cronparsertest_inIndia
...
NO-JIRA: CronParserTest is failing in Indian StandardTime
2019-11-17 06:56:20 +01:00
65de327369
AMQ-7300 - Remove unnecessary call to sequence updater as read is already volatile
2019-09-06 12:19:23 -04:00
4db2656066
AMQ-7300 - Improve performance of LongSequenceGenerator
...
LongSequenceGenerator now uses an AtomicLongFieldUpdater instead of
synchronized
2019-09-06 11:55:54 -04:00
02548777c2
AMQ-7298 - rework redelivery message tracking to ensure no duplicate suppression (and dlq) in error for local transaction batches that failover
2019-09-04 12:24:42 +01:00
7e72fbc98b
[AMQ-7254] Fix OSGi headers
2019-08-05 08:38:47 +02:00
de3f77063f
AMQ-7234 - fix up memory usage wait timeout such that topic pfc in a transaction can see connection context state changes, fix and test
2019-06-21 16:55:13 +01:00
82b3d02fc2
Remove dependency activemq-http and activemq-stomp
2019-06-06 14:42:49 +01:00
30abc45f62
no jira - remove extraneous printStackTrace, ex is propagated up
2019-04-18 14:38:30 +01:00
487d4a112e
AMQ-7185 - track durable sub prepared acks in preCommit callback and release/remove on xa outcome, avoid duplicate delivery; fix and test
2019-04-17 14:31:11 +01:00
b9bcd2fcc3
AMQ-7165 - ensure failover updated uris are additive such that statically configured uris are respected
2019-03-12 12:24:20 +00:00
4b51f8b66c
AMQ-7132 - ActiveMQ reads lots of index pages upon startup (after a graceful or ungraceful shutdown)
2019-01-14 10:54:26 -05:00
b65fedf4dd
NO-JIRA: CronParserTest is failing in Indian StandardTime
2018-11-23 15:49:04 +05:30
a87b61e8be
Enable secure processing on all DocumentBuilderFactory.newInstance()
2018-11-22 10:24:43 +00:00
02c1e6d8f2
AMQ-7047 - clarify documentation
2018-09-24 07:35:00 -04:00
0b71b06ac8
Revert "AMQ-7004 - Improved logging in Failover Transport"
...
This reverts commit 7974e8c099
2018-09-04 06:53:00 -04:00
1e31df9800
AMQ-7047 - Switch default for hostname verification to be false for
...
server
For the client it makes sense to have it true by default but for the
server it makes sense to have it false by default
2018-08-31 13:04:14 -04:00
69fad2a135
Add support for hostname verification
2018-08-31 06:39:49 -04:00
8bb3a77270
AMQ-5917 - fix sync on SslContext lazy initialisation
2018-08-20 12:23:53 +01:00
7974e8c099
AMQ-7004 - Improved logging in Failover Transport
2018-07-30 07:56:33 -04:00
5b1412ddfd
Avoid overflow errors - see KAFKA-4290
...
Add test for overflow values
Bind test sockets to free ports
2018-07-27 08:32:36 -04:00
0b76d3a0ea
AMQ-7021 - add unsynchronised accessors to destination map for usage with rw lock from abstract region; allow concurrent read of the destination map
2018-07-26 10:42:10 +01:00
7f4851f31c
[AMQ-7013] Added final for thread safety
2018-07-18 15:13:31 -06:00
e9a64b1c72
[AMQ-7013] Introduce JenkinsHash to XATransactionID
2018-07-18 10:39:29 -06:00
2b64b7b04f
AMQ-4706 - ensure we log the first warn and include the failure reason
2018-07-05 17:34:30 +01:00
5ebee0ace7
AMQ-7000 - ensure server sessions with closed active sessions get removed from the pool on stop, fix and test
2018-06-26 11:07:04 +01:00
004be56127
AMQ-2659 - make configurable based on xaAckMode, otherwise pure xa case can default to autoack in error. Additional tests
2018-06-13 11:48:43 +01:00
db8c771b2a
AMQ-6968 Ensure that the correct exception is thrown
...
Allow the original exception that triggered the failure to be thrown
from the packet send methods
2018-05-21 16:39:58 -04:00
191e4ffbe6
AMQ-6963
...
Fix calling the toString() method in case of different log level.
2018-05-15 18:46:36 +03:00
2a95348182
AMQ-6959
...
Avoid creating a Throwable in case of non-trace logging
2018-05-14 15:11:10 +03:00
703b7b1510
AMQ-6901 - Add NPE check inside DestinationMap filter
2018-02-16 14:32:24 -05:00
2ce1c1352f
AMQ-6901 - Make sure proper policy is used to configure a destination
...
When multiple wildcard policies exist in a hierarchy it was possible for
the wrong policy to be selected when configuring a destination
2018-02-16 10:41:33 -05:00
d0dab2e88b
AMQ-6894: limit poison exception message to 1024
2018-02-07 19:28:55 +01:00
4535e8f097
AMQ-6884 - Replacing printStackTrace() with logging statement
2018-01-11 07:27:03 -05:00
39caca7cf6
AMQ-6327 - Remove System.out.println
2017-12-22 18:16:14 -05:00
051e2b791c
AMQ-6327 - getNextScheduledTime() returns incorrect time when working with day of month
2017-12-20 21:47:47 +02:00
26eab53723
Javadoc typo fix and cleanup
...
This mostly fixes the url1/url2 copy and paste problem. It uses a bit more readable property syntax and introduces a single sentence (plain text) summary for class Javadoc and adds some links.
2017-12-18 21:28:28 -05:00
5fa0bbd515
AMQ-6871 - By default only send generic platform details
...
The default behavior by the OpenWire client will be to send generic
platform details to the server with a new flag to send more specific
information.
2017-12-06 08:41:51 -05:00
e793260573
[AMQ-6831, AMQ-6771] trigger eofexception on read -1 - AMQ6522Test
2017-10-11 00:20:44 +01:00
a21dd40527
AMQ-6823 Ensure that MessagePull is works across HTTP transport
...
The MessagePull command needs to have the transients initialized such
that the pull operation works across transports that use XStream or
other marshaling that doesn't performs custom serialization.
2017-09-25 13:26:18 -04:00
6e33507bf2
AMQ-6820 - Properly handle ClosedChannelException
...
When a ClosedChannelException occurs inside SelectorSelection properly
call the transport listener onError() method to handle cleanup and
logging.
2017-09-21 08:14:19 -04:00
61d3231d36
AMQ-6809 Fix issue where stream message getBytes returned wrong value
...
StreamMessage implementation should return zero when the full value of a
written byte array has been consumed before then returning -1 on the
next read. Ands fix and additional testing of ActiveMQStreamMessage
2017-09-20 15:50:09 -04:00
6b27708ae1
AMQ-6811 - moving ActiveMQMessageIsMarshalled test to src/test/java
2017-09-15 12:20:44 -04:00
f82993d9c2
AMQ-6811 - fix reduceMemoryFootprint when no message body
...
ReduceMemoryFootprint will now properly detect that a message is
marshalled even if there is no message body so the headers can be
cleared out after message send
2017-09-15 10:11:46 -04:00
3cd5529f50
[AMQ-6771] fix off by one on input stream read long check, with test
2017-07-18 12:28:12 +01:00
8c218ee05d
[AMQ-6771] do linear sequential scan of journal when validating checksums - remove batch reads via seek/read which depend on write batch size
2017-07-17 12:18:25 +01:00
499347542c
[no jira] make networkConsumerIds visible in toString of consumerinfo to aid tracing consumers in a network via transport trace logging
2017-07-07 16:01:49 +01:00
a9fe4e33c3
[maven-release-plugin] prepare for next development iteration
2017-06-27 13:41:28 -04:00
5f0d6943cb
[maven-release-plugin] prepare release activemq-5.15.0
2017-06-27 13:41:01 -04:00
d2c0eddaad
[AMQ-6691] allow dlq flag to be set via jmx to allow retry op after a restart - use destinations element for long term persistence
2017-05-31 12:39:48 +01:00
2e2d5ddd3d
https://issues.apache.org/jira/browse/AMQ-6669
...
Respect the wireFormat.maxFrameSize option on WS and WSS transports
allowing binary content larger than 65535
2017-05-04 16:37:53 -04:00
2bd3379932
[AMQ-6068] make full cleanup of the rar managed connection conditional on a user specified client id being present
2017-05-04 11:08:32 +01:00
172c29091e
AMQ-6651: Add new implementations of the writeUTF8 and readUTF8 methods that are based on Apache Harmony code. This also avoid some code duplication that was occurring.
2017-04-10 10:49:17 -04:00
63b2e5c4ea
[AMQ-6494] fix check order of close state for onException handler
2017-04-06 10:23:16 +01:00
b64ac1dd77
[AMQ-6646] improve error reporting to include url
2017-04-04 17:30:29 +01:00
679db08db3
[AMQ-6643] ensure a wildcard virtual topic subscriber is restricted to the wildcard destination - avoid duplicate and spurious dispatch. fix and test
2017-04-04 10:16:48 +01:00
90b808ab98
AMQ-6603 Stop tracking producer if creation failed
...
Track the message producer create and ensure it is not recreated on
failover if the creation resulted in an error response. Add failover
level tests to cover consumer and producer failed create tracking.
2017-02-28 16:17:32 -05:00
8641928553
[AMQ-6603] ensure failover does not track consumer creation that fails with an exception, fix and test. Thanks for the test Tadayoshi Sato
2017-02-28 17:17:18 +00:00
0cf64783d2
AMQ-6602 - fix java 7 incompatibility
2017-02-24 06:36:57 -05:00
1f53b124bc
AMQ-6602 - Removing lambdas for java 7 compatibility
2017-02-23 10:56:57 -05:00
79069598b1
AMQ-6606 - fix typo
2017-02-23 10:21:54 -05:00
fe5164a404
AMQ-6602: Fix race condition in TaskRunnerFactory
...
Fixing a race condition in TaskRunnerFactory where if multiple threads
call createTaskRunner() at the same time some threads might see the
executor as null (if it hasn't finished initializing) leading to the
creation of extra DedicatedTaskRunner objects instead of sharing a
PooledTaskRunner.
2017-02-23 10:20:13 -05:00
f6bf823ded
AMQ-6599 - Properly apply soTimeout value to TcpTransport
...
https://issues.apache.org/jira/browse/AMQ-6599
The soTimeout value needs to be applied to the TcpTransport as well as
the socket because the NIO transports use the value later on when
establishing a connection
2017-02-17 08:03:50 -05:00
85181d630c
[AMQ-6548] ensure any pending xa transaction is marked rollback only on delivery failure exception from on message, before delegating to potential clientInternalExceptionListener. Variant of patch applied with additional test - thanks to Andrey Dyachikhin for the patch inspiration
2017-01-17 16:51:27 +00:00
2769298cf6
https://issues.apache.org/jira/browse/AMQ-6555
...
Fixing Scheduler so that a rescheduled task will first cancel the
existing task so it does not get orphaned from the task map. Also
fixing Topic start so that it will only start once and not twice.
2017-01-10 10:25:15 -05:00
27238b2dd7
https://issues.apache.org/jira/browse/AMQ-6535
...
Fixing the auto+nio+ssl transport so that the protocol detection task
will properly terminate on timeout and not continue to run. Also
lowered the default detection timeout to 15 seconds instead of 30
seconds to match the InactivityMonitor default.
2016-12-12 11:17:19 -05:00
6a0c65828a
Revert "fix up createPublisher contract to throw on null topic param, match the java doc"
...
the java doc allows null for an anonymous publish - the check needs to go in TopicRequestor part of the jdk
This reverts commit 29ecfd6cdb
2016-12-02 13:57:44 +00:00
29ecfd6cdb
fix up createPublisher contract to throw on null topic param, match the java doc
2016-12-02 12:46:32 +00:00
b6bca3976c
[AMQ-6517] make pre dispatch redelivery policy check optional jms.redeliveryPolicy.preDispatchCheck=false
2016-11-24 17:02:37 +00:00
016ae05d0e
https://issues.apache.org/jira/browse/AMQ-6489
...
Adding a new ActiveMQXASslContextFactory and jndi support for it
in ActiveMQSslInitialContextFactory
2016-11-04 08:31:19 -04:00
be24a133ef
This closes #88 (merged as a65ac586). More file permissions fixes.
2016-11-03 14:26:34 -04:00
d5a929c0d2
This closes #205 . Won't fix. (fix even more file permissions)
2016-11-03 14:11:40 -04:00
d54d046b8a
This closes #185 . Won't fix. (fix more file permissions)
2016-11-03 11:54:33 -04:00
629ee28568
https://issues.apache.org/jira/browse/AMQ-6495
...
State variables shared across threads in the transport need to be marked
volatile.
2016-11-02 12:57:39 -04:00
d1f42bd01e
https://issues.apache.org/jira/browse/AMQ-6474
...
ASYNC_TASKS executor not being shut down on stop with no other users in
service.
2016-11-02 12:41:49 -04:00
11541e8608
https://issues.apache.org/jira/browse/AMQ-6489
...
Add support for SSL configurations using JNDI.
2016-10-31 12:03:33 -04:00
0a80165a99
https://issues.apache.org/jira/browse/AMQ-6477
...
simplifying isMarshalled method
2016-10-27 15:53:01 -04:00
7c3bb40100
https://issues.apache.org/jira/browse/AMQ-6477
...
ReduceMemoryFootprint now applies to non-persistent messages if they
have been marshalled and topics now clear memory after the recovery
policy check
2016-10-25 10:19:03 -04:00
338a74dfa4
https://issues.apache.org/jira/browse/AMQ-6470 - Remove unused ControlCommand handling in client
2016-10-18 12:04:11 +02:00
e91f5c8062
AMQ-6454 - ensure message.acknowledge throws if consumer has closed and message has been released broker side
2016-10-07 09:57:28 +01:00
72650a0b8b
https://issues.apache.org/jira/browse/AMQ-6449
...
Disabling doclint now only activates for JDK 8
2016-10-03 07:37:53 -04:00
02082b1aec
NO-JIRA: More Java 8 JavaDoc fixes - also fixed findbugs for Java 8
2016-09-30 14:36:44 -04:00
5385fd1bb3
https://issues.apache.org/jira/browse/AMQ-6446 - use shared logger and pepend statements with connection counter. Old behaviour or per connection logger can be obtained with trace=true&jmxPort=0
2016-09-30 14:05:42 +01:00
634b42016a
https://issues.apache.org/jira/browse/AMQ-5486 - allow selector manager to reject tasks - org.apache.activemq.transport.nio.SelectorManager.rejectWork leaving the default to caller runs policy. This allows a broker to implement qos for existing connections by forcing others away
2016-09-28 12:15:50 +01:00
08695ab303
https://issues.apache.org/jira/browse/AMQ-6184 - add workQueueCapacity config property default to 0 where a value > 0 swaps out the dsynchQ for a capicity limited blocking queue. This allows the core pool to grow on demand as before but also allows work to be queued when necessary
2016-09-28 10:04:22 +01:00
09456480b8
https://issues.apache.org/jira/browse/AMQ-6431
...
Fixing BitArrayBin to not overflow in certain cases with numbers larger
than Int max
2016-09-23 14:30:37 -04:00
2b99ffcc22
https://issues.apache.org/jira/browse/AMQ-6433
...
Generating a new equals method in TypeConversionSupport so the proper
null checks exist
2016-09-23 08:02:22 -04:00
f25e7ab47f
https://issues.apache.org/jira/browse/AMQ-6434
...
Rewriting logic in finally block of PooledTaskRunner to avoid using a
return statement
2016-09-23 07:51:11 -04:00
6630e81379
https://issues.apache.org/jira/browse/AMQ-6435 - destination mbean query api
2016-09-19 16:22:44 +02:00
9ab94883a8
https://issues.apache.org/jira/browse/AMQ-6420
...
Properly copying wire format options map before applying to the
transport when using auto transports so that the options do not get
cleared and will be used for all future connections
2016-09-07 07:42:13 -04:00
98c5866c75
https://issues.apache.org/jira/browse/AMQ-6418
...
Properly setting the transport properties on the
AutoNIOSSLTransportServer and fixing the Stomp protocol to set the peer
certs when using auto+ssl
2016-09-06 10:17:05 -04:00
ed0e786b60
https://issues.apache.org/jira/browse/AMQ-6414
...
Changing the nio+ssl transports to trigger a serviceRead after start up
to prevent blocking. The prevents the channels from not reading in
certain cases, most notably with the auto+nio+ssl transport when used
for a network bridge. Also added a couple tests and changed a network
bridge test to test out auto+nio+ssl.
2016-09-01 11:39:46 -04:00
06a21dbbb3
[maven-release-plugin] prepare for next development iteration
2016-08-02 09:03:37 -04:00
71cbc65283
[maven-release-plugin] prepare release activemq-5.14.0
2016-08-02 09:02:54 -04:00
eb9c584fbd
https://issues.apache.org/jira/browse/AMQ-6373
...
More tests and cleanup
2016-08-01 12:27:34 -04:00
e73ab34837
https://issues.apache.org/jira/browse/AMQ-6383
...
https://issues.apache.org/jira/browse/AMQ-6373
Adding a new flag that can be specified on a network bridge to allow
forcing of subscriptions to be durable. Cleaned up some unit tests.
2016-08-01 10:02:56 -04:00
Pascal Schumacher
gtully
Matt Daley
Christopher L. Shannon (cshannon)
Jean-Baptiste Onofré
Jonathan Gallimore
Alan Protasio
212726340
Colm O hEigeartaigh
giliva
Jeff Genender
jgoodyear
Timothy Bish
saivr1t
saivr1t
Andrei Shakirin
Sami Nurminen
Bernd
Hiram Chirino
Hadrian Zbarcea
Michael L. Bloom
Dejan Bosanac