Commit Graph

121 Commits

Author SHA1 Message Date
Bosanac Dejan a259537d65 https://issues.apache.org/jira/browse/AMQ-4485 - adding LevelDB variant of NegativeQueueTest
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1484484 13f79535-47bb-0310-9956-ffa450edef68
2013-05-20 14:09:59 +00:00
Hiram R. Chirino 665c3ab33b Added a leveldb version of the queue browsing test.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1484319 13f79535-47bb-0310-9956-ffa450edef68
2013-05-19 17:20:38 +00:00
Hiram R. Chirino e168b3cd6e No need to send MQTT debugging to console anymore.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1484318 13f79535-47bb-0310-9956-ffa450edef68
2013-05-19 17:20:30 +00:00
Hiram R. Chirino 5e13c20707 Fixes failing AMQ2902 test.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1484306 13f79535-47bb-0310-9956-ffa450edef68
2013-05-19 16:32:51 +00:00
Hiram R. Chirino 4aac5a6bf3 Fixes AMQ-4544: Cant send MQTT message to AMQP endpoints
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1484143 13f79535-47bb-0310-9956-ffa450edef68
2013-05-18 16:39:35 +00:00
Hiram R. Chirino 2621463a28 Fixes deprecation warning.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1484141 13f79535-47bb-0310-9956-ffa450edef68
2013-05-18 16:39:10 +00:00
Hiram R. Chirino be7cef6438 AMQ2584Test was failing on linux due to kahadb taking too long to complete. Scaled the test back a bit
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483963 13f79535-47bb-0310-9956-ffa450edef68
2013-05-17 19:54:09 +00:00
Bosanac Dejan 620523a597 https://issues.apache.org/jira/browse/AMQ-4000 - initial implementation of keeping track of durable subscribers over network and unregister them appropriately
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483827 13f79535-47bb-0310-9956-ffa450edef68
2013-05-17 14:27:48 +00:00
Hiram R. Chirino d43d08aa1c Give the leveldb 3 broker virt topic network test a more appropriate file name. Also add a single broker test for leveldb.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483809 13f79535-47bb-0310-9956-ffa450edef68
2013-05-17 14:04:00 +00:00
Gary Tully 6f124c16f7 https://issues.apache.org/jira/browse/AMQ-4539 - add JMSActiveMQBrokerPath string property and brokerPath attribute via jmx message view, the list length is the current number of network hops
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483600 13f79535-47bb-0310-9956-ffa450edef68
2013-05-16 23:03:17 +00:00
Hiram R. Chirino ef6df68831 Fixes issue in AMQ-4296: Implement a pure LevelDB test for the StoreQueueCursorNoDuplicateTest and fix the bug that was causing it to fail.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483582 13f79535-47bb-0310-9956-ffa450edef68
2013-05-16 21:50:25 +00:00
Hiram R. Chirino 7071102b13 Fix for AMQ-4296 : add a LevelDB test for the AMQ2149TEst
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483538 13f79535-47bb-0310-9956-ffa450edef68
2013-05-16 19:58:23 +00:00
Timothy A. Bish 66c8f9c4b8 Add missing license header
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483115 13f79535-47bb-0310-9956-ffa450edef68
2013-05-15 22:45:44 +00:00
Timothy A. Bish f46b184f6c fix and test for: https://issues.apache.org/jira/browse/AMQ-4413
For durable subscriptions the PrefetchSubscription can't drop messages in dispatchPending otherwise they are never added back into the pending cursor. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1483111 13f79535-47bb-0310-9956-ffa450edef68
2013-05-15 22:22:39 +00:00
Bosanac Dejan e06685fe81 https://issues.apache.org/jira/browse/AMQ-4000 - as part of this feature we need to properly send advisories when durable sub unregisters
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1482790 13f79535-47bb-0310-9956-ffa450edef68
2013-05-15 12:31:09 +00:00
Gary Tully 58b9a83fe8 https://issues.apache.org/jira/browse/AMQ-4532 - fix and test - ensure disposed exception is propagated to clients on vm server shutdown
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1482117 13f79535-47bb-0310-9956-ffa450edef68
2013-05-13 21:43:39 +00:00
Timothy A. Bish e731c39af7 ix and test for: https://issues.apache.org/jira/browse/AMQ-4531
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1481984 13f79535-47bb-0310-9956-ffa450edef68
2013-05-13 17:45:18 +00:00
Timothy A. Bish 2bd0e5703e apply fix and patch for: https://issues.apache.org/jira/browse/AMQ-4530
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1481930 13f79535-47bb-0310-9956-ffa450edef68
2013-05-13 15:36:03 +00:00
Timothy A. Bish 540b1c6a89 fix for: https://issues.apache.org/jira/browse/AMQ-4518
Allow purge to disable message expiration check when paging in Messages to be purged.  Avoids attempts at sending messages to a DLQ during a purge operation and in firing advisory messages for expired messages which are being thrown out by request. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1480731 13f79535-47bb-0310-9956-ffa450edef68
2013-05-09 17:50:26 +00:00
Bosanac Dejan fc8c8d339e https://issues.apache.org/jira/browse/AMQ-4522 - set timeToLive when sending a message using JMX
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1480189 13f79535-47bb-0310-9956-ffa450edef68
2013-05-08 09:15:17 +00:00
Timothy A. Bish 0bb9013769 Fix for: https://issues.apache.org/jira/browse/AMQ-4517
Don't send MessageDLQd advisory for Message that aren't sent to a DLQ

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1480087 13f79535-47bb-0310-9956-ffa450edef68
2013-05-07 21:17:34 +00:00
Timothy A. Bish d7aaca5034 Fix and test for: https://issues.apache.org/jira/browse/AMQ-4513
Makes the locking in RegionBroker a bit more fine grained.  We hold a lock only for a short time and allow destination adds that aren't on the same destination to continue on concurrently.  

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1479963 13f79535-47bb-0310-9956-ffa450edef68
2013-05-07 16:13:18 +00:00
Christian Posta 866440dfb2 Fix for https://issues.apache.org/jira/browse/AMQ-4516 - Don't decrement topic enqueues when messages are expired
Removed the call to decrement the counters, and added unit test

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1479925 13f79535-47bb-0310-9956-ffa450edef68
2013-05-07 14:39:25 +00:00
Gary Tully bf071376b5 https://issues.apache.org/jira/browse/AMQ-3097 - apply patch with some additional unit test, with thanks
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1478973 13f79535-47bb-0310-9956-ffa450edef68
2013-05-03 20:43:59 +00:00
Timothy A. Bish 3a8eb74a9f Fix and test for: https://issues.apache.org/jira/browse/AMQ-4505
When a broker was stopping it was sending out a cluster update after tearing down its bridges so any client connected to it would lose its awareness of other brokers in the cluster. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1478835 13f79535-47bb-0310-9956-ffa450edef68
2013-05-03 15:21:25 +00:00
Bosanac Dejan 7450a32ae7 https://issues.apache.org/jira/browse/AMQ-4495 - always get a max batch of messages from the store
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1478823 13f79535-47bb-0310-9956-ffa450edef68
2013-05-03 14:50:56 +00:00
Timothy A. Bish b9cc24bdb6 Swap expected and actual so that they match the intent of the assertion, otherwise the error message is misleading.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1478395 13f79535-47bb-0310-9956-ffa450edef68
2013-05-02 14:53:52 +00:00
Christian Posta 2a1bc72c0c test to help debug hawtio not being able to browse DLQ...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1478266 13f79535-47bb-0310-9956-ffa450edef68
2013-05-02 04:33:10 +00:00
Timothy A. Bish e777126d30 fix for: https://issues.apache.org/jira/browse/AMQ-4501
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1478184 13f79535-47bb-0310-9956-ffa450edef68
2013-05-01 20:53:51 +00:00
Gary Tully 4742c7d86f https://issues.apache.org/jira/browse/AMQ-4504 - ensure all dests in a composite get a chance to dispatch to a consumer after an ack
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1478183 13f79535-47bb-0310-9956-ffa450edef68
2013-05-01 20:49:08 +00:00
Timothy A. Bish d52e5910a5 apply patch: https://issues.apache.org/jira/browse/AMQ-4500
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1477830 13f79535-47bb-0310-9956-ffa450edef68
2013-04-30 21:12:28 +00:00
Bosanac Dejan 5cbb4bfc12 https://issues.apache.org/jira/browse/AMQ-4467 - cursor memory usage when pfc is off
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1477574 13f79535-47bb-0310-9956-ffa450edef68
2013-04-30 11:44:03 +00:00
Gary Tully 66e8011e9e https://issues.apache.org/jira/browse/AMQ-4485 - ensure cursor updates in same order as store orderindex via beforeCompletion with index lock. The before completion tracks ordered work that first thread completes as a unit. All updates to a destination are combined to a single sync, such that there is no cursor contention between transactions
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1475734 13f79535-47bb-0310-9956-ffa450edef68
2013-04-25 12:47:20 +00:00
Hiram R. Chirino 163ad5d4a9 Fix for AMQ4472: We can eagerly close a txed consumer if it has not delivered any messages.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1471673 13f79535-47bb-0310-9956-ffa450edef68
2013-04-24 21:01:24 +00:00
Gary Tully 705b3c5f9d https://issues.apache.org/jira/browse/AMQ-4472 - test case that shows the problem with prefetched messages and delayed close till commit
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1470459 13f79535-47bb-0310-9956-ffa450edef68
2013-04-22 11:29:48 +00:00
Timothy A. Bish 7e53814928 Fix and test for: https://issues.apache.org/jira/browse/AMQ-4475
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1469013 13f79535-47bb-0310-9956-ffa450edef68
2013-04-17 18:07:24 +00:00
Timothy A. Bish 3bf9d0cceb fix for: https://issues.apache.org/jira/browse/AMQ-4212
fix for: https://issues.apache.org/jira/browse/AMQ-2832

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1468171 13f79535-47bb-0310-9956-ffa450edef68
2013-04-15 18:08:15 +00:00
Timothy A. Bish 3f9b6ed391 fix and test for: https://issues.apache.org/jira/browse/AMQ-4469
Rewrote the unit test as a JUnit 4 test and remove hard coded 61616 port dep. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1467510 13f79535-47bb-0310-9956-ffa450edef68
2013-04-12 23:02:48 +00:00
Timothy A. Bish 2aba7845db AMQ-4212 Add KahaDB v4 data for use in testing the upgrade to v5 that this issue requires.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1467377 13f79535-47bb-0310-9956-ffa450edef68
2013-04-12 17:42:18 +00:00
Bosanac Dejan 15affd0755 https://issues.apache.org/jira/browse/AMQ-3706 - improve rebalance distribution which is more apparent when only two brokers are involved
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1467241 13f79535-47bb-0310-9956-ffa450edef68
2013-04-12 11:52:15 +00:00
Timothy A. Bish c7308a1183 Add a KahaDB trace entry for reference.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1467106 13f79535-47bb-0310-9956-ffa450edef68
2013-04-11 21:45:16 +00:00
Timothy A. Bish 2aff82c47a fix and test for: https://issues.apache.org/jira/browse/AMQ-4464
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1466131 13f79535-47bb-0310-9956-ffa450edef68
2013-04-09 17:05:21 +00:00
Timothy A. Bish a80c711d78 fix for: https://issues.apache.org/jira/browse/AMQ-4463
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1465814 13f79535-47bb-0310-9956-ffa450edef68
2013-04-08 22:34:04 +00:00
Bosanac Dejan 585a966a9b https://issues.apache.org/jira/browse/AMQ-4461 - priority backup with multiple brokers
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1465683 13f79535-47bb-0310-9956-ffa450edef68
2013-04-08 16:58:21 +00:00
Timothy A. Bish 0054941a53 fix and test for: https://issues.apache.org/jira/browse/AMQ-4356
The actual Durable subscription wasn't getting removed from the Store so on restart they were recovered.  

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1464729 13f79535-47bb-0310-9956-ffa450edef68
2013-04-04 20:30:00 +00:00
Timothy A. Bish 1b38caacf4 fix junit warnings. https://issues.apache.org/jira/browse/AMQ-4437
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1464584 13f79535-47bb-0310-9956-ffa450edef68
2013-04-04 15:00:05 +00:00
Timothy A. Bish 8e388b86d6 fix and test for: https://issues.apache.org/jira/browse/AMQ-4361
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1464165 13f79535-47bb-0310-9956-ffa450edef68
2013-04-03 19:22:16 +00:00
Timothy A. Bish 14b91d41b5 patch some test code: https://issues.apache.org/jira/browse/AMQ-4296
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1462346 13f79535-47bb-0310-9956-ffa450edef68
2013-03-28 23:12:48 +00:00
Timothy A. Bish f7f294f059 test code updates to address: https://issues.apache.org/jira/browse/AMQ-4415
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1462252 13f79535-47bb-0310-9956-ffa450edef68
2013-03-28 18:42:40 +00:00
Timothy A. Bish b52c371cd9 fix for: https://issues.apache.org/jira/browse/AMQ-4364
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1462210 13f79535-47bb-0310-9956-ffa450edef68
2013-03-28 16:36:57 +00:00