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
Timothy Bish
4d6f4d7475
https://issues.apache.org/jira/browse/AMQ-6263
...
Encode the incoming messageId value into a string using type prefixes
and decode them on the way out to ensure that we preserve the original
AMQP MessageId type and value.
2016-04-26 18:08:11 -04: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)
4e27618ddd
NO-JIRA : Adding 5.13.3 schema identifier
2016-04-26 11:16:58 +00:00
Timothy Bish
765a010d04
https://issues.apache.org/jira/browse/AMQ-5621
...
Add sleep back which allows the producers to wait for the bridge
formation.
2016-04-25 18:41:00 -04:00