Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-06 18:18:58 +00:00
Code Issues Packages Projects Releases Wiki Activity
10,345 Commits 22 Branches 100 Tags
Commit Graph

864 Commits

Author SHA1 Message Date
gtully
01cfa7727d AMQ-6361 - fix additional test regression on topic sub expiry AMQ4083Test,MessageEvictionTest 2016-07-26 13:45:41 +01:00
Christopher L. Shannon (cshannon)
3953b9aaef https://issues.apache.org/jira/browse/AMQ-6373 
Adding a new OpenWire command called BrokerSubscriptionInfo in order to
help synchronize durable subs across a network bridge.  Added OpenWire
version 12.  For dynamicallyIncludedDestination durable subs will now be
synchronized on a bridge reconnect as long as the bridge supports
conduitSubscriptions and dynamicOnly=false
 2016-07-25 11:56:13 -04:00
gtully
6cc2c1190d AMQ-6361 - fix contention over expiry processing with expiry task and client expiry ack, unit test regression sorted. 2016-07-22 15:18:31 +01:00
Christopher L. Shannon (cshannon)
9f7d70ba0d https://issues.apache.org/jira/browse/AMQ-6366 
Need to make sure that the durableDestinations set on the duplex bridge
are only topics
 2016-07-20 08:33:45 -04:00
Timothy Bish
e05db7cb5c https://issues.apache.org/jira/browse/AMQ-6273 
increment the connect attempt count explicitly to ensure reconnect
policy options are applied.
 2016-07-19 17:26:24 -04:00
Christopher L. Shannon (cshannon)
39184e2fb0 https://issues.apache.org/jira/browse/AMQ-6366 
Fixing the duplex bridge case for restarting durable subscriptions when
dynamicOnly is false
 2016-07-19 11:31:44 -04:00
Timothy Bish
cd5ea6c27f https://issues.apache.org/jira/browse/AMQ-6361 
Honor the expired ack from the client as the authority on expiration
 2016-07-15 15:08:26 -04:00
Christopher L. Shannon (cshannon)
42dabb7a7a https://issues.apache.org/jira/browse/AMQ-6357 
Preventing a divide by 0 error by taking a local reference to the
prefetch size to guarantee that the value doesn't change after the > 0
check
 2016-07-14 10:07:02 -04:00
Christopher L. Shannon (cshannon)
d635a36940 https://issues.apache.org/jira/browse/AMQ-6352 
Fixing PList size tracking by moving the null assignment on removal to
after the onRemoval method is called to make sure that the decrement is
done properly.
 2016-07-12 10:27:57 -04:00
Timothy Bish
31c55f7510 https://issues.apache.org/jira/browse/AMQ-6339 
Add support for AMQP client to connect using WebSockets.
 2016-06-30 14:52:40 -04:00
Timothy Bish
4e23adfcc9 https://issues.apache.org/jira/browse/AMQ-6340 
combine the lists in the correct order for later redispatch.
 2016-06-29 12:57:30 -04:00
Christopher L. Shannon (cshannon)
6be36305f6 https://issues.apache.org/jira/browse/AMQ-6337 
Checking for the correct number of arguments before reflectively
invoking a method in DefaultAuthorizationMap
 2016-06-23 20:34:50 +00:00
Timothy Bish
03785a4d53 https://issues.apache.org/jira/browse/AMQ-6334 
Fix error handling for connection establishment on the bridge.
 2016-06-23 11:03:06 -04:00
Dejan Bosanac
1faa4afa90 https://issues.apache.org/jira/browse/AMQ-6331 - Honor excluded destinations in static routing on network connectors 2016-06-21 15:07:30 +02:00
Christopher L. Shannon (cshannon)
a953f11d0e https://issues.apache.org/jira/browse/AMQ-6323 
Applying reduceMemoryFootprint for persistent Topic messages
 2016-06-14 14:36:37 +00:00
Dejan Bosanac
9f9b0fb26a https://issues.apache.org/jira/browse/AMQ-6322 - Introduce timeout in network bridge for waiting broker infos 2016-06-14 14:29:11 +02:00
gtully
f548aafa81 move test utility to broker module to allow reuse from jdbc module tests 2016-06-10 10:20:33 +01:00
Timothy Bish
98d2000833 https://issues.apache.org/jira/browse/AMQ-6275 
Avoid unnecessary connection state lookup leading to lock ordering
issues.
 2016-06-09 12:10:09 -04:00
Jonathan Malek
6bf5987921 A fix for AMQ-6310 
Checking for leading wildcard in the prefix for a virtualtopic,
modifying the behavior of shouldDispatch in the VirtualTopicInterceptor.
 2016-06-04 16:51:27 -07:00
gtully
1f9b139f59 test for uuid temp request/reply from camel across network 2016-06-02 16:58:03 +01:00
gtully
29b833fe8e fix shadowing and ensure close of connection, ci... 2016-05-26 11:30:32 +01:00
gtully
fe9d99e7a0 AMQ-3166 - implement rollbackOnlyOnAsyncException such that async exceptions on transactional sends or acks result in the transaction being marked rollback only and commit failing with an exception. Test that shows current state of play using alwaySendSync or AsyncCallback. rollbackOnlyOnAsyncException enabled by default. 2016-05-25 11:24:43 +01:00
gtully
b4e35fe8a3 AMQ-4181 - revert mod to testQueueBrowserWith2ConsumersInterleaved which cause intermittent ci failure - browse is a snapshot at time of creation. tidy up some gaps in pagein logic sync 2016-05-23 13:29:39 +01:00
Timothy Bish
0883011147 Fix data dir path change that shouldn't have been committed with the 
other fixes.
 2016-05-18 11:02:14 -04:00
gtully
c2230fda4b https://issues.apache.org/jira/browse/AMQ-6286 - refine fix to distinguish multiple consumers in a transaction, verify insertion at head will preserve order 2016-05-18 10:09:39 +01:00
Timothy Bish
2c3046b816 Fix test timing out on slow spinning disks. 
On a local drive with heave I/O this test took over 2.5 minutes to
complete, CI machines can see similar times, bumped timeout to 5 minutes
to account for this range.
 2016-05-17 13:00:56 -04:00
Christopher L. Shannon (cshannon)
1241e4120a https://issues.apache.org/jira/browse/AMQ-6293 
Fixing Queue destination statistics in dropMessage by adding sync in
between the check for dropped and actually dropping the message plus
fixing dequeue stats so messages aren't counted twice
 2016-05-14 16:20:41 +00:00
Timothy Bish
b9334960e0 Add some additional time to the wait for completion assert. On a 
sufficiently loaded system 30s is not quite enough.  This is
reproducable if run while a heavily I/O based application is also
running in the background.
 2016-05-13 12:50:13 -04:00
Christopher L. Shannon (cshannon)
d3ea5c4f9f https://issues.apache.org/jira/browse/AMQ-5621 
Fixing LinkStealingTest by adding a wait because removeConnection
may not have been called yet when checking if the removeException
exists the first time
 2016-05-10 11:44:17 +00:00
gtully
604f707d4d https://issues.apache.org/jira/browse/AMQ-6286 - refactor insertAtHead from pendinglist to ordered variant 2016-05-10 11:45:27 +01:00
gtully
f47b370573 https://issues.apache.org/jira/browse/AMQ-6286 extend strictOrderDispatch to retain order of redispatched messages for a single consumer 2016-05-09 23:06:19 +01:00
Timothy Bish
6cf8bed0c5 https://issues.apache.org/jira/browse/AMQ-5621 
Update test with additional checks and logging to try and see what is
happening when it is failing in CI.
 2016-05-09 16:57:39 -04:00
gtully
9fc2661049 validate selector aware vt can give topic semantics by dropping messages when there is no consumer. Do selector cache plugin once to avoid adaptor check on each dispatch 2016-05-06 17:12:15 +01:00
Timothy Bish
5009b0c03b https://issues.apache.org/jira/browse/AMQ-6247 
Allow the provider position to be read from the system.
 2016-05-06 09:37:51 -04:00
Timothy Bish
5096463b00 https://issues.apache.org/jira/browse/AMQ-6281 
Deprecate the copyMessage option and remove usage, always copy a
forwarded message.
 2016-05-05 12:59:29 -04:00
Quinn Stevenson
1ccd17791b AMQ-6274 - set originalDestination for composite destinations 
This closes #184
 2016-05-05 11:38:48 -04:00
Timothy Bish
a28a091c55 https://issues.apache.org/jira/browse/AMQ-6264 
Fire advisory for slow consumer outside the pending lock.
 2016-05-04 16:32:01 -04:00
Christopher L. Shannon (cshannon)
297eadf746 https://issues.apache.org/jira/browse/AMQ-6267 
Added two new properties for configuration to a network bridge,
advisoryPrefetchSize and advisoryAckPercentage.  By default
advisoryPrefetchSize is set to 0, which is disabled, and will use the
prefetchSize value unless otherwise set.  Also added validation to
prefetchSize to make sure it is greater than 0 as 0 is not allowed.
 2016-04-27 14:11:05 +00:00
Timothy Bish
8031d77f98 https://issues.apache.org/jira/browse/AMQ-6251 
Make field volatile since it is written to outside of any locks and read
both in and out of locking.
 2016-04-26 10:04:21 -04:00
Christopher L. Shannon (cshannon)
11622b3af3 https://issues.apache.org/jira/browse/AMQ-6256 
Moving beforeMarshall back to the store implementations because we don't
want all store implementations to marshall (such as memory store)

This reverts commit b9b98a45cee484b112dadeffa2d9a874c4ffe280.
 2016-04-18 12:34:25 +00:00
Christopher L. Shannon (cshannon)
9c8bd3360f https://issues.apache.org/jira/browse/AMQ-6222 
Reverting the change to move clearMarshalledState into the callback
listener as beforeMarshall is now called before the async message add

Revert 75990ef14a092b629bf8d2127bc4786e51b31684
 2016-04-18 11:49:16 +00:00
Christopher L. Shannon (cshannon)
b9b98a45ce https://issues.apache.org/jira/browse/AMQ-6256 
Moving beforeMarshall call out of the store and into the actual
destination
 2016-04-15 14:17:00 +00:00
Timothy Bish
19fd084a83 https://issues.apache.org/jira/browse/AMQ-6252 
Update for some added thread safety.  Adds method healthStatus that will
regenrate the status from the healthList data which is more intuitive
than the getCurrentStatus which doesn't update state and requires
periodic calls to healthList to capture current metrics.
 2016-04-14 16:53:17 -04:00
Timothy Bish
f9682b802f https://issues.apache.org/jira/browse/AMQ-6127 
LOG at info level for when broker is being stopped and a new connection
is not being accepted.
 2016-04-12 16:28:23 -04:00
Timothy Bish
c1b58d3373 https://issues.apache.org/jira/browse/AMQ-6239 
Refactor the iterator implementation in the PrioritizedPendingList to
not copy elements and instead use the level iterators.  Add some
additional tests.
 2016-04-12 11:35:03 -04:00
gtully
2a8218a9a8 https://issues.apache.org/jira/browse/AMQ-6151 - retain list for redeliveries and combine for dispatch/iteration such that redeliveries retain per priority order after prefetch 2016-04-06 15:09:36 +01:00
gtully
a3a8c1c525 https://issues.apache.org/jira/browse/AMQ-6215 - support 0 maxBrowsePageSize and maxExpirePageSize such that lazyDispatch ensures highest priority messages is available to a pull consumer 2016-04-05 13:23:06 +01:00
Christopher L. Shannon (cshannon)
b2327db3b7 https://issues.apache.org/jira/browse/AMQ-6133 
Disabling async queue message store when persistJMSRedelivered is turned
on for a destination.  That flag will cause a sync update later on
dispatch which can cause a race condition if the original message add is
processed after the update.  This can cause a duplicate message to be
stored.
 2016-04-01 16:40:45 +00:00
Timothy Bish
48ba714b30 https://issues.apache.org/jira/browse/AMQ-6210 
Clean up and apply filtering for temp destinations to removeConsumer as
well.  

This closes #175
 2016-03-28 14:40:00 -04:00
Timothy Bish
f3ecc293f0 https://issues.apache.org/jira/browse/AMQ-6210 
Don't cache selectors for temp destinations.
 2016-03-28 14:34:20 -04:00