102599ee28
Adds some additional tests for the connection pool around error handling
...
when JMSSecurityException is returned from the broker.
2016-04-20 18:34:29 -04:00
10478c313e
https://issues.apache.org/jira/browse/AMQ-5621
...
Update tests to not use hardcoded port for the transport connector and
remove the unneeded sleep calls with proper test setup
2016-04-20 15:16:36 -04:00
b65c0d1be4
https://issues.apache.org/jira/browse/AMQ-5510
...
https://issues.apache.org/jira/browse/AMQ-5534
PooledConnectioFactory added reconnection support but can break if the
holder of the connection adds their own ExceptionListener as the
PooledConnection doesn't protect the internal ExceptionListener from
replacement which leads to cases where the loaned Connection is not
automatically closed so that the next create returns the same failed
connection.
2016-04-20 09:48:06 -04:00
8a30026e82
Drop back to original iterations now and give some extra time on test
...
timeouts.
2016-04-19 12:54:18 -04:00
34eb1ee959
https://issues.apache.org/jira/browse/AMQ-6259 - mqtt-over-ws configuration
2016-04-19 16:02:45 +02:00
b027e65553
https://issues.apache.org/jira/browse/AMQ-5153
...
https://issues.apache.org/jira/browse/AMQ-6254
Store the original subscribed destination along with the target
destination in the subscription info object to ensure that wildcard
subscriptions remain linked.
2016-04-19 09:53:58 -04:00
6541bef52d
fix logger name
2016-04-18 15:05:31 +01:00
3560d9123d
AMQ-6248 fix logging statement to use the connected URI.
2016-04-18 09:53:59 -04:00
23a5beb86c
https://issues.apache.org/jira/browse/AMQ-6248
...
Prevent conccurent calls to handleTransportFailure from closing an
already reconnected transport instance.
2016-04-18 09:45:45 -04:00
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 b9b98a45ce
2016-04-18 12:34:25 +00:00
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 75990ef14a
2016-04-18 11:49:16 +00:00
c8af70f094
https://issues.apache.org/jira/browse/AMQ-5819
...
Only apply the initialReconnectDelay on the first reconnection attempt
after a connected transport has failed.
2016-04-15 12:49:49 -04:00
1ffac14f6e
https://issues.apache.org/jira/browse/AMQ-6256
...
cleanup imports
2016-04-15 14:23:54 +00:00
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
b9f9f03829
https://issues.apache.org/jira/browse/AMQ-6256
...
Calling beforeMarshall on messages when they async stored before the
store task is run and before consumer dispatch to prevent two threads
from trying to mutate the message state at the same time.
2016-04-15 13:01:21 +00:00
9c929b6870
Revert " https://issues.apache.org/jira/browse/AMQ-6218 "
...
Reverting commit in favor of a better approach
This reverts commit ea09159a40
2016-04-15 11:48:18 +00:00
6d20cba0e4
https://issues.apache.org/jira/browse/AMQ-6253 - mqtt composite destinations support for virtual topic subscriptions
2016-04-15 11:00:39 +02:00
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
092c56d70c
https://issues.apache.org/jira/browse/AMQ-6250
...
Checking for null before closing the journal in
MultiKahaDBPersistentAdapter. Also protecting against multiple calls to
start and stop.
2016-04-14 18:39:14 +00:00
530c1a8193
https://issues.apache.org/jira/browse/AMQ-6240 - tidy up test and reduce duration. reuse closeTimeout on rollback during close which is the case here
2016-04-14 12:25:11 +01:00
15dc6cc765
https://issues.apache.org/jira/browse/AMQ-6246
...
Fix loop to not skip the composite split code.
2016-04-13 18:53:28 -04:00
aaecdff8b4
https://issues.apache.org/jira/browse/AMQ-6245
...
Don't log the pull timed out messages that might still be in the
unconsumed list during rollback of unconsumed messages
2016-04-13 16:53:00 -04:00
82330793e9
https://issues.apache.org/jira/browse/AMQ-5621
...
Clean up the test, use timeouts and add a few more iterations to try and
reproduce recent CI failures from this test.
2016-04-13 15:17:14 -04:00
28e4090d95
https://issues.apache.org/jira/browse/AMQ-6230
...
Temporarily ignoring karaf camel tests until karaf integration is fixed
The failed test is causing the smoke tests to fail (so PRs don't pass)
and also seems to be keeping a broker alive so that other tests are
breaking as well
2016-04-13 15:27:30 +00:00
66953e1a29
https://issues.apache.org/jira/browse/AMQ-6244
...
Merging ActiveMQBytesMessage compression fix
This closes #177
2016-04-13 15:20:27 +00:00
7a61718e02
https://issues.apache.org/jira/browse/AMQ-6244 - reset ActiveMQBytesMessage 'compressed' flag after restoring compressed content
2016-04-13 14:19:06 +00:00
7f86825337
NO-JIRA - Adding activemq-junit dependency to activemq-unit-tests
2016-04-13 13:21:48 +00:00
77d46dc139
https://issues.apache.org/jira/browse/AMQ-6240 use sendTimout on sync rollback on close such that a blocked connection won't block a close
2016-04-13 11:55:59 +01:00
08d7977402
https://issues.apache.org/jira/browse/AMQ-5462
...
Remove dead code from session create method.
2016-04-12 19:32:29 -04:00
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
332a8225fa
https://issues.apache.org/jira/browse/AMQ-6178
...
https://issues.apache.org/jira/browse/AMQ-6147
Update Qpid JMS to v0.9.0 and Qpid Proton to 0.12.1
2016-04-12 13:57:21 -04:00
5ec4513ffb
https://issues.apache.org/jira/browse/AMQ-5923
...
Adding missing assertion statements
2016-04-12 15:52:26 +00:00
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
485fcafcdf
https://issues.apache.org/jira/browse/AMQ-5923
...
Updating tests to check prioritized messages as well
2016-04-12 14:13:52 +00:00
cbad8babe5
https://issues.apache.org/jira/browse/AMQ-6203
...
Adding a flag to enable or disable Ack Compaction
Currently defaults to enabled for 5.14.0 and above
2016-04-12 13:30:10 +00:00
e69c2cbad6
https://issues.apache.org/jira/browse/AMQ-6142
...
Moving the bytes copy to the parent Message class to solve this this
issue for all message types as that is the root cause
2016-04-11 12:31:57 +00:00
837da7e582
Revert " https://issues.apache.org/jira/browse/AMQ-6221 "
...
Reverting commit to keep sync out of the client messages
This reverts commit e0c5499964
2016-04-11 12:17:15 +00:00
b1c55fdc74
https://issues.apache.org/jira/browse/AMQ-6235
...
Honor the initialReconnectDelay configuration in all cases.
2016-04-08 12:28:19 -04:00
c8d96c6e8e
remove compile dep on dbcp2 in favour or generic datasource
2016-04-08 11:10:17 +01:00
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
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
666029e024
https://issues.apache.org/jira/browse/AMQ-6223
...
Include the junit integration jar in the lib/extra area of the binary
distro.
2016-04-04 12:43:34 -04:00
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
993d561947
https://issues.apache.org/jira/browse/AMQ-6118 - CRL Checking via OCSP
2016-04-01 13:07:17 +02:00
a9a1498d27
Add assert messages to test that failed in CI
2016-03-31 17:54:48 -04:00
98165c4b69
https://issues.apache.org/jira/browse/AMQ-6228
...
Create a better error message that for the invalid frame size error.
2016-03-31 16:52:34 -04:00
0fb24cc4c1
Allow some extra time on the consumer wait to account for slow CI boxes
2016-03-30 14:23:33 -04:00
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
f3ecc293f0
https://issues.apache.org/jira/browse/AMQ-6210
...
Don't cache selectors for temp destinations.
2016-03-28 14:34:20 -04:00
9a866cf567
https://issues.apache.org/jira/browse/AMQ-5486
...
Default to caller runs policy on task rejection.
2016-03-28 13:55:09 -04:00
Timothy Bish
Dejan Bosanac
gtully
Christopher L. Shannon (cshannon)
Brian D. Johnson