Dain Sundstrom
eb19487b66
If thread context class loader is null use the class loader of the FactoryFinder class
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513003 13f79535-47bb-0310-9956-ffa450edef68
2007-02-28 22:05:55 +00:00
James Strachan
44bafc3e03
added a little helper method to make it easy to wait on a broker being shut down in Java code
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512764 13f79535-47bb-0310-9956-ffa450edef68
2007-02-28 14:21:29 +00:00
Robert Davies
60a526c36b
now check for correct order of messages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512643 13f79535-47bb-0310-9956-ffa450edef68
2007-02-28 07:29:43 +00:00
Robert Davies
9f15a47340
only use debug logging when re-filling a batch
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512642 13f79535-47bb-0310-9956-ffa450edef68
2007-02-28 07:28:48 +00:00
Robert Davies
dc0241343a
tidied up the way messages are page in for a durable subscriber
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512640 13f79535-47bb-0310-9956-ffa450edef68
2007-02-28 07:23:37 +00:00
Robert Davies
14c605feab
Have separate child Usage Managers - one for producers, one for consumers.
...
This has been done so that paged-in messages do not have to contend for memory
with fast producers
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512637 13f79535-47bb-0310-9956-ffa450edef68
2007-02-28 07:17:55 +00:00
Robert Davies
6b38f803bc
should be a synchronized call around getVmLockSet()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512497 13f79535-47bb-0310-9956-ffa450edef68
2007-02-27 23:42:03 +00:00
Robert Davies
9ba5e1921c
tidy up the setting of the default policy
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512259 13f79535-47bb-0310-9956-ffa450edef68
2007-02-27 14:05:16 +00:00
Robert Davies
1cc049c5d0
enable statistics for the broker created for this test (count for destinations relies on it)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512156 13f79535-47bb-0310-9956-ffa450edef68
2007-02-27 06:43:24 +00:00
Hiram R. Chirino
274f677ecb
Adding test provided in AMQ-1165
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@512104 13f79535-47bb-0310-9956-ffa450edef68
2007-02-27 01:33:59 +00:00
James Strachan
9583b5fc9f
added a helper class so that system properties can be used to overload the default prefix for auto-created data directories. Also patched the test cases to use a relative to target/ directory for easier cleaning
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511947 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 19:01:22 +00:00
James Strachan
611ecd2a01
removed dead file
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511941 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 18:32:03 +00:00
James Strachan
63b2d6837d
added patch for AMQ-1099
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511939 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 18:16:06 +00:00
James Strachan
c3fd0a65b1
applied patch for AMQ-1128
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511912 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 17:34:15 +00:00
James Strachan
cbb458ce8b
changed the default policy to use an offset from localhost
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511881 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 16:35:54 +00:00
James Strachan
3753442b18
added jndi support for BlobTransferPolicy
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511841 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 15:03:24 +00:00
James Strachan
52c22cca2e
added a simple default cut of the DefaultBlobUploadStrategy implementation along with a test case for the URI based configuration
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511798 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 13:13:54 +00:00
James Strachan
12a5355b2c
disabled logging to System.err to tidy up the test run in maven
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511791 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 12:34:54 +00:00
James Strachan
3013c2020b
updated wiki links in source code to point to the graduated site
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511784 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 11:04:18 +00:00
James Strachan
6c57f721c2
added explicit disconnect after Chris T.'s patch
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511781 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 10:55:53 +00:00
James Strachan
c0fb0c5584
fixed openwire test case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511758 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 08:57:19 +00:00
James Strachan
53bf323e74
added another helper method and fixed up some broken javadoc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511753 13f79535-47bb-0310-9956-ffa450edef68
2007-02-26 08:49:21 +00:00
James Strachan
05a8cba7d0
An improvement of AMQ-1075 so that the BLOB upload policy can be configured more easily together with a simple provider of the BlobUploadStrategy (with the actual implementation detail stubbed out). Also added brokerUploadUrl to BrokerInfo so that the broker can inform the clients where to upload out-of-band messages to. Finally added a JMSXMimeType helper method to the ActiveMQ extension API for doing selectors on MIME types
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511598 13f79535-47bb-0310-9956-ffa450edef68
2007-02-25 20:31:23 +00:00
Hiram R. Chirino
26198c2094
Backported fix to AMQ-1165
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511464 13f79535-47bb-0310-9956-ffa450edef68
2007-02-25 08:34:49 +00:00
Robert Davies
48522098f5
chekc if debug is enabled before calling debug
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511073 13f79535-47bb-0310-9956-ffa450edef68
2007-02-23 19:53:23 +00:00
James Strachan
8cf4795b94
added the first cut of version 3 of the wire format which now supports BlobMessage for out-of-band (or later on in-band) BLOBs for AMQ-1075
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511045 13f79535-47bb-0310-9956-ffa450edef68
2007-02-23 18:50:52 +00:00
James Strachan
b77d70a1b1
rolled back change of toString() which was made for StompConnect as we can use Queue.getQueueName() / Topic.getTopicName() instead
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@511032 13f79535-47bb-0310-9956-ffa450edef68
2007-02-23 17:41:28 +00:00
Robert Davies
481e717292
take out a println() that crept in
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@510995 13f79535-47bb-0310-9956-ffa450edef68
2007-02-23 15:59:17 +00:00
Robert Davies
9e14f67b40
Fixed vroke test case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@510991 13f79535-47bb-0310-9956-ffa450edef68
2007-02-23 15:51:23 +00:00
Robert Davies
f7e9206ae5
Add a default policy entry, now that FixedSizeSubsctionRecoveryPolicy is no longer set by default on a Topic.
...
It was a memory issue for large messages.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@510899 13f79535-47bb-0310-9956-ffa450edef68
2007-02-23 10:46:43 +00:00
James Strachan
d85794c17f
Applied patch from Tom Vijlbrief for AMQ-724
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@510843 13f79535-47bb-0310-9956-ffa450edef68
2007-02-23 06:04:41 +00:00
Robert Davies
b88db246b5
synchronization changes
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509912 13f79535-47bb-0310-9956-ffa450edef68
2007-02-21 06:17:17 +00:00
Robert Davies
8613f58d16
tidy imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509903 13f79535-47bb-0310-9956-ffa450edef68
2007-02-21 05:54:32 +00:00
Robert Davies
f92e5b587a
repeater test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509731 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 20:09:23 +00:00
Robert Davies
5da043be84
testlets of performance
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509729 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 20:08:05 +00:00
Robert Davies
32a4c47204
small op
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509728 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 20:05:00 +00:00
Robert Davies
76c466ddef
small op
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509720 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 19:40:20 +00:00
Robert Davies
341a1d4753
small op
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509717 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 19:25:30 +00:00
James Strachan
b006e61e4f
Handle duplicate destinations & concurrency issues better
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509706 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 18:59:02 +00:00
James Strachan
bca88fee18
Used toString() on destinations to avoid issues with StompConnect
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509705 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 18:58:34 +00:00
Robert Davies
f5b1b831b6
set stats collection to false by default - a real performance hog - ironically
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509612 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 15:40:08 +00:00
Robert Davies
c74558bfde
Add some additional crude throttling. With cursors being limited by how much they can
...
can page into memory as well as the producer, you can get live locks around space usage -
if the allocation reaches 100%
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509575 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 14:26:27 +00:00
Robert Davies
b0b602121e
set the prefetch to something sensible (this is actually a key bit!)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509566 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 14:01:55 +00:00
Robert Davies
d0beb32cb8
add waiting to aquire a lock held by the store
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509565 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 14:01:18 +00:00
Robert Davies
b9814c408c
only set the initialized flag = true after obtaining the lock on the data files
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509564 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 14:00:35 +00:00
Robert Davies
c46003fd3b
tighten up on message reference counting
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509563 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 13:59:41 +00:00
Robert Davies
8de60cf980
try to deliver messages if there's enough space
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509552 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 13:22:27 +00:00
Robert Davies
3a2caf427d
by default, there should not be a subscription recovery policy (and it leaks memory)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509550 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 13:20:40 +00:00
Robert Davies
40f5aadcd3
Add test case for slow durable consumer
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509534 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 12:31:15 +00:00
Robert Davies
7b317ba7ad
Log the error that caused the rollback
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509486 13f79535-47bb-0310-9956-ffa450edef68
2007-02-20 09:58:34 +00:00