Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
9,336 Commits 21 Branches 99 Tags 88 MiB
Commit Graph

9336 Commits

Author SHA1 Message Date
Timothy Bish a2720c4653 https://issues.apache.org/jira/browse/AMQ-6293 
Clean up the test, the times were causing CI failure.  Turn off
persistence and fix a couple other things, reduced time to 2.5 secs
while still reproducing with fix removed.
 2016-05-16 11:02:20 -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 ab434ee776 Refactor test which has some flawed assumptions about the incoming 
messages based on subscriptions that it makes.  Adds better thread
safety as well.
 2016-05-13 18:30:44 -04:00
Timothy Bish 15405af2e6 https://issues.apache.org/jira/browse/AMQ-6292 
allow for batch writes of forwarded acks.
 2016-05-13 14:56:01 -04: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
Timothy Bish cc849e7440 https://issues.apache.org/jira/browse/AMQ-6291 
Simplify the selector close in doStop, the run method no longer tries to
close this after it has been registered and assigned.
 2016-05-13 11:31:15 -04:00
Timothy Bish ff99872263 https://issues.apache.org/jira/browse/AMQ-6209 
Better management of shared resources between the background run thread
and the main start / stop thread.  Makes sure to cleanup all resources
before finally throwing on stop to prevent leaking and resources.
 2016-05-13 11:13:28 -04:00
gtully d7b5a62bb0 https://issues.apache.org/jira/browse/AMQ-6286 - variant on test with n consumers sharing a session 2016-05-13 15:50:13 +01:00
gtully 3c0a4d960e unit test to verify matching durable sub can statically forward topic 2016-05-12 22:11:25 +01:00
Christopher L. Shannon (cshannon) c8a6171d04 https://issues.apache.org/jira/browse/AMQ-6288 
Switching the checkpoint lock to a readlock when forwarding acks to
prevent other journal updates from being blocked.
 2016-05-12 14:39:12 +00:00
Timothy Bish 2e64abc38a https://issues.apache.org/jira/browse/AMQ-6290 
Close failed connection on start if the reconnect on exception flag is
enabled.
 2016-05-11 16:03:19 -04:00
Christopher L. Shannon (cshannon) e53e340262 https://issues.apache.org/jira/browse/AMQ-6288 
The ack compaction task now acquires the checkpoint lock while it runs
to prevent a checkpoint from running at the same time unintentionally.
Also, getJournalLocation is now protected by a try/catch to handle
errors.
 2016-05-11 13:16:57 +00:00
Timothy Bish c81a9348ee Need to test the underlying connection to ensure we aren't using an old 
one that isn't cleaned up since each checked grabs a new
PooledConnection wrapper.
 2016-05-10 15:41:58 -04:00
Timothy Bish 71893f1434 Allow the HTTP test to have extra time to wait for all messages to 
arrive as the transmission rate is much slower.
 2016-05-10 10:59:12 -04:00
Timothy Bish 3da9b0720e https://issues.apache.org/jira/browse/AMQ-5621 
Remove hard coded port as the bridge brokers method doesn't need the
port to be fixed.  Turn off JMX since the test doesn't use it.
 2016-05-10 10:05:05 -04:00
Timothy Bish 809d5b9bc8 https://issues.apache.org/jira/browse/AMQ-5621 
Clean up, remove sleep and some unused code.
 2016-05-10 09:56:19 -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
Timothy Bish 91d277ccb0 Make the result value in the listener volatile since it is read from and 
written to in multiple threads without sync.
 2016-05-09 16:11:06 -04:00
Christopher L. Shannon (cshannon) 91213010b3 https://issues.apache.org/jira/browse/AMQ-6285 
Added an extra isShutdown() failsafe check when detecting if the
checkpoint thread should start
 2016-05-09 19:35:02 +00:00
Timothy Bish 100c5e0b59 Add waitFor to check that once the async processing kicks in the pool 
clears the bad connection and a new one is returned from the pool.
 2016-05-09 15:15:43 -04:00
Christopher L. Shannon (cshannon) 7bdcca1bda https://issues.apache.org/jira/browse/AMQ-6285 
Properly nulling out the scheduler service in MessageDatabase after it
is shutdown on a store close so that if the store is restarted the
thread will properly restart.
 2016-05-09 19:06:40 +00:00
Christopher L. Shannon (cshannon) db3f8b3554 Revert "https://issues.apache.org/jira/browse/AMQ-6285" 
This reverts commit 60b0c4f85a.

Inadvertantly commited a bunch of changes by mistake
 2016-05-09 19:05:52 +00:00
Christopher L. Shannon (cshannon) 60b0c4f85a https://issues.apache.org/jira/browse/AMQ-6285 
Properly nulling out the scheduler service in MessageDatabase after it
is shutdown on a store close so that if the store is restarted the thread will
properly restart.
 2016-05-09 19:03:38 +00:00
gtully 1a8e17fbc3 tidy up test 2016-05-09 12:51:28 +01: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
gtully 1de7e7e8a3 tackle ci intermittent failure - think with prefetch extension it is not guarenteed that second consumer will get a dispatch 2016-05-06 13:54:12 +01:00
gtully fc9ad9f023 tackle intermittent ci failure, think possibe all messages are dispatched before pause 2016-05-06 12:17:07 +01:00
gtully 9a35c3731b fix ci failure when less than 4% disk space 2016-05-06 12:10:26 +01: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
Hiram Chirino 7fd5fa9253 Add a method that Karaf can use to get the description of the command. Depends on a change in karaf too to get this to work. 2016-05-05 09:26:33 -04:00
gtully 65cef69130 https://issues.apache.org/jira/browse/AMQ-5603 - reverting default preallocatonScope to entire_journal b/c async only really works for ssd 2016-05-05 13:06:42 +01:00
Timothy Bish e3a68717f1 Fix race in test due to async processing of the SecurityException, start 
might throw but the connection doesn't fire the exception listener until
afterwards which is what triggers the pool to close the connection.
 2016-05-04 17:15:13 -04:00
gtully 1c4108545c https://issues.apache.org/jira/browse/AMQ-6277 - journal getNextLocation needs too passes to skip past if target is not initialized 2016-05-04 22:09:06 +01: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
Timothy Bish d1e2b76809 https://issues.apache.org/jira/browse/AMQ-5621 
Update tests to not use hard coded broker port.
 2016-05-04 14:39:38 -04:00
gtully 231679d936 https://issues.apache.org/jira/browse/AMQ-5603 - don't async preallocate to keep match data file count 2016-05-04 16:15:55 +01:00
gtully 555cd2b6bb https://issues.apache.org/jira/browse/AMQ-5603 - catch interrupted on chunked zeros case 2016-05-03 17:25:14 +01:00
Dejan Bosanac 2e00891827 https://issues.apache.org/jira/browse/AMQ-6278 - revisit LeaseDatabaseLocker log levels 2016-05-03 14:53:31 +02:00
gtully ba77b9f55a https://issues.apache.org/jira/browse/AMQ-6277 - tidy up logic that determines recovery location so that we don't recovery from the end of the journal in error on normal restart. This avoids suprious recovery logging 2016-05-03 12:47:49 +01:00
Dejan Bosanac 3dd86d04e8 https://issues.apache.org/jira/browse/AMQ-6276 - remove fileserver webapp 2016-05-03 12:39:50 +02:00
gtully 4f43a21212 https://issues.apache.org/jira/browse/AMQ-5603 - one more journal in the mix for this test with async preallocation 2016-05-03 11:36:47 +01:00
Timothy Bish 27799fec97 https://issues.apache.org/jira/browse/AMQ-5880 
Update to latest MQTT client release to resolve this issue.
 2016-05-02 16:21:34 -04:00
gtully 62bdbb0db5 https://issues.apache.org/jira/browse/AMQ-5603 - add preallocationScope=full_journal_async that will preallocate a journal in advance or use to avoid latency jitter on journal rotation. Added none option to disable preallocation 2016-04-29 16:57:28 +01:00
Timothy Bish 3c342ffce4 Add some additional checks for valid state. 2016-04-27 14:50:43 -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