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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
a5f74d673d
remove unused line of code (it was bad anyway!)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509227 13f79535-47bb-0310-9956-ffa450edef68
2007-02-19 15:48:38 +00:00
a3b3a497fb
added fix for AMQ-1161
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509200 13f79535-47bb-0310-9956-ffa450edef68
2007-02-19 13:45:34 +00:00
0cda6b0d58
fix some synchronization problems
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509115 13f79535-47bb-0310-9956-ffa450edef68
2007-02-19 06:56:59 +00:00
0384cabd9d
for getValue() ensure the StoreEntry is up to date
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@508721 13f79535-47bb-0310-9956-ffa450edef68
2007-02-17 07:30:08 +00:00
6ac27998aa
for getValue() ensure the StoreEntry is up to date
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@508719 13f79535-47bb-0310-9956-ffa450edef68
2007-02-17 07:10:03 +00:00
c8e6ff245b
ObjectMarshaller cannot write to stream directly - it'll get corrupted
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@508534 13f79535-47bb-0310-9956-ffa450edef68
2007-02-16 18:56:11 +00:00
1a33eb61fb
added support for temporary destinations and support more polymorphic request/reply logic in clients
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@508489 13f79535-47bb-0310-9956-ffa450edef68
2007-02-16 16:54:00 +00:00
ee64b03ff5
patch for https://issues.apache.org/activemq/browse/AMQ-1163
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@507792 13f79535-47bb-0310-9956-ffa450edef68
2007-02-15 02:58:58 +00:00
141b0faedb
Fixed The StoreTest that was failing on windows due to file handles not being properly closed.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@507736 13f79535-47bb-0310-9956-ffa450edef68
2007-02-14 23:05:04 +00:00
6ddca19690
Fix for failing MapContainerTest on windows. All file handles were not being closed on a Store.close() call.
...
also updated to make more use of generics.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@507717 13f79535-47bb-0310-9956-ffa450edef68
2007-02-14 22:23:04 +00:00
ccf3f3c60d
updates for https://issues.apache.org/activemq/browse/AMQ-894 - provided option to disable statistics gathering
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@506415 13f79535-47bb-0310-9956-ffa450edef68
2007-02-12 11:20:05 +00:00
a324484867
amq store - just like the quick store (cut n' paste) - difference is optimizations for recoverying in flight messages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504999 13f79535-47bb-0310-9956-ffa450edef68
2007-02-08 18:46:54 +00:00
ee4bb53a7d
tell the PendingMessageCursor how many messages you want - for more efficent polling from store
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504798 13f79535-47bb-0310-9956-ffa450edef68
2007-02-08 05:55:56 +00:00
1d882e981c
adding a patch to fix AMQ-1157 allowing a broker security context to be used to allow destinations to be created on startup etc.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504586 13f79535-47bb-0310-9956-ffa450edef68
2007-02-07 15:35:10 +00:00
6e7e3abf5d
fix some problems in Quick Journal - now message containers are using Kaha maps instead of lists
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504501 13f79535-47bb-0310-9956-ffa450edef68
2007-02-07 11:12:53 +00:00
e17e5eca88
Updated version to remove the "incubator" bit.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504248 13f79535-47bb-0310-9956-ffa450edef68
2007-02-06 19:09:51 +00:00
3b78804dbc
fix text case by disabling spooling to disk
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504228 13f79535-47bb-0310-9956-ffa450edef68
2007-02-06 18:06:25 +00:00
5c7af47332
make sure next entry will be set properly in recovery
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504032 13f79535-47bb-0310-9956-ffa450edef68
2007-02-06 08:40:14 +00:00
2e0f676c9b
see http://www.nabble.com/ActiveMQConnection.createConnectionConsumer-bug--tf3159712.html#a8819449
...
properties not being set correctly
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504023 13f79535-47bb-0310-9956-ffa450edef68
2007-02-06 08:23:38 +00:00
fb3f71d895
ensure writer isn't null in removeDataFile()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@504007 13f79535-47bb-0310-9956-ffa450edef68
2007-02-06 06:27:11 +00:00
aa18c5d6fc
ensure that init() is called on index - before clearing the index
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@503856 13f79535-47bb-0310-9956-ffa450edef68
2007-02-05 20:31:17 +00:00
c4c9f0b983
use Kaha MapContainer for message storage instead of the Kaha ListContainer
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@503694 13f79535-47bb-0310-9956-ffa450edef68
2007-02-05 14:15:36 +00:00
ee9f05ea52
use Kaha MapContainer for message storage instead of the Kaha ListContainer
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@503681 13f79535-47bb-0310-9956-ffa450edef68
2007-02-05 13:58:15 +00:00
0859f30a91
use Kaha MapContainer for message storage instead of the Kaha ListContainer
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@503680 13f79535-47bb-0310-9956-ffa450edef68
2007-02-05 13:57:43 +00:00
5b49189cfe
Tidy up the choice of Index types for the Map and List container
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@503177 13f79535-47bb-0310-9956-ffa450edef68
2007-02-03 07:24:10 +00:00
93c67fe701
Addition of Indexes based on BTree and Hashing
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@503176 13f79535-47bb-0310-9956-ffa450edef68
2007-02-03 06:53:59 +00:00
be35271fdc
Port of rev 501500 fix for https://issues.apache.org/activemq/browse/AMQ-1140
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@501506 13f79535-47bb-0310-9956-ffa450edef68
2007-01-30 18:24:29 +00:00
b54ff7acff
Updated support for configurable Cursor types from the Destination Policy Map
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@500863 13f79535-47bb-0310-9956-ffa450edef68
2007-01-28 19:39:30 +00:00
0c0be94a31
Updated support for configurable Cursor types from the Destination Policy Map
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@500862 13f79535-47bb-0310-9956-ffa450edef68
2007-01-28 19:39:02 +00:00
f0d9464da0
remove the caching (as was causing memory leaks) in the ListContainer
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499827 13f79535-47bb-0310-9956-ffa450edef68
2007-01-25 16:20:42 +00:00
10abf6727a
fix for http://issues.apache.org/activemq/browse/AMQ-1082
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499798 13f79535-47bb-0310-9956-ffa450edef68
2007-01-25 13:58:38 +00:00
fb56fd9c76
fix for http://issues.apache.org/activemq/browse/AMQ-1082
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499797 13f79535-47bb-0310-9956-ffa450edef68
2007-01-25 13:58:02 +00:00
b036d4d2fa
fix for memory leaks woth non-persistent messages - see http://www.nabble.com/OutOfMemoryErrors-again-tf3083798.html
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499760 13f79535-47bb-0310-9956-ffa450edef68
2007-01-25 12:23:57 +00:00
1b8148cd37
increase average size overhead of a message to 500 bytes
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499758 13f79535-47bb-0310-9956-ffa450edef68
2007-01-25 12:19:40 +00:00
0552f4a1b0
change log level to debug for exceptio thrown when disposing of local transport
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499752 13f79535-47bb-0310-9956-ffa450edef68
2007-01-25 11:54:12 +00:00
22e007f0a3
log when transport reconnects successfully
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499746 13f79535-47bb-0310-9956-ffa450edef68
2007-01-25 11:41:42 +00:00
af249b6b86
use different broker names for the remote and local broker
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499478 13f79535-47bb-0310-9956-ffa450edef68
2007-01-24 16:56:43 +00:00
30716b1519
add synchronize around pending
...
- see http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8550623
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499173 13f79535-47bb-0310-9956-ffa450edef68
2007-01-23 22:50:15 +00:00
21391ceab4
add synchronize around add() - see http://www.nabble.com/Is-anyone-else-seeing-messages-stuck-on-a-queue--tf3027911.html#a8550623
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499169 13f79535-47bb-0310-9956-ffa450edef68
2007-01-23 22:38:12 +00:00
1a448be825
applied patch for http://issues.apache.org/activemq/browse/AMQ-1077
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@499032 13f79535-47bb-0310-9956-ffa450edef68
2007-01-23 14:29:26 +00:00
28a7312f2e
corrected spelling mistake in raised exception
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@498926 13f79535-47bb-0310-9956-ffa450edef68
2007-01-23 05:55:24 +00:00
0aac7f5d5c
fix for AMQ-1134 so that stomp connections are cleared up by the broker if a stomp client is killed without disconnecting properly
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@497898 13f79535-47bb-0310-9956-ffa450edef68
2007-01-19 18:36:41 +00:00
6e26195cd8
fix for AMQ-1130 to use LONGBLOB rather than BLOB for persisting on mysql to avoid the 64k limit
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@496976 13f79535-47bb-0310-9956-ffa450edef68
2007-01-17 09:37:36 +00:00
f490982c38
updated patch for https://issues.apache.org/activemq/browse/AMQ-1010
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@496571 13f79535-47bb-0310-9956-ffa450edef68
2007-01-16 02:05:48 +00:00
f19a3a66d6
Tidied up the async dispatch option
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@494950 13f79535-47bb-0310-9956-ffa450edef68
2007-01-10 19:40:33 +00:00
b21113962b
Disable nio tests since they are not working on OS X
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@494582 13f79535-47bb-0310-9956-ffa450edef68
2007-01-09 21:14:59 +00:00
79f326ad53
ignoring the mutex for shutdown causes sporadic failures in open-wire
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@494331 13f79535-47bb-0310-9956-ffa450edef68
2007-01-09 06:51:17 +00:00
e349089a8d
Fix for http://issues.apache.org/activemq/browse/AMQ-1117
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493696 13f79535-47bb-0310-9956-ffa450edef68
2007-01-07 10:43:38 +00:00
e76feb6b8e
fix for http://issues.apache.org/activemq/browse/AMQ-1119
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493573 13f79535-47bb-0310-9956-ffa450edef68
2007-01-06 21:15:01 +00:00
8e8b82024b
Adding an intial cut of an NIO based Transport. This could be really hand to help brokers scale up in situations where it needs to accecpt a large number of connections.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493241 13f79535-47bb-0310-9956-ffa450edef68
2007-01-05 23:23:14 +00:00
e30a9dddde
Added a JPA based ReferenceStoreAdapter implementation
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493226 13f79535-47bb-0310-9956-ffa450edef68
2007-01-05 23:05:40 +00:00
c1612b5e06
moving to the activemq-jpa-module.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493196 13f79535-47bb-0310-9956-ffa450edef68
2007-01-05 21:25:15 +00:00
f89d4dcaeb
guard against MessageEvaluationContext dropping the message whilst doing the check
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493032 13f79535-47bb-0310-9956-ffa450edef68
2007-01-05 13:39:42 +00:00
aebb18cc57
increase the default cache size
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492995 13f79535-47bb-0310-9956-ffa450edef68
2007-01-05 11:49:09 +00:00
d2bff5d8ed
might as well use the generic stuff - sigh
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492994 13f79535-47bb-0310-9956-ffa450edef68
2007-01-05 11:48:37 +00:00
720a19c5bf
optimization for large number of queue consumers
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492993 13f79535-47bb-0310-9956-ffa450edef68
2007-01-05 11:47:49 +00:00
a664b0b917
Quick Store bug fixes and added a bench mark test
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492518 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 11:00:45 +00:00
88eab92328
Quick Store bug fixes and added a bench mark test
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492517 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 11:00:31 +00:00
ced50c9940
Quick store bug fixes.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492511 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 10:39:04 +00:00
62c850b7de
rollback change.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492474 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 09:38:09 +00:00
a4c432ab45
Fixed a ton of Quick store bugs that were found when running the QuickStoreLoadTester.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492472 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 09:36:07 +00:00
75b1c94ddc
Fixed a ton of Quick store bugs that were found when running the QuickStoreLoadTester.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492471 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 09:34:46 +00:00
158dbc66e7
go back to less granular synchronization
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492461 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 08:59:12 +00:00
481fc1ee3a
- Big refactor of the QuickJournal:
...
- Move it to it's own package org.apache.activemq.store.quick
- Brought in all the latest JournalPersistenceAdaptor enhancements
- It now uses the AsyncDataManager as the Journal implemenation which has better read performance
- Instead of forcing all PersistenceAdaptors to support external references, we now move all the message reference methods to a new set of interface class (MesageReferenceAdaptor)
- Enhanced a few Kaha container classes so that they take advantage of Generics
- Added a Kaha based MesageReferenceAdaptor impementation
- Strategy for deleting old journal log files is now in place so that disk space can be reclaimed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492380 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 01:48:20 +00:00
0afb7f934f
- Big refactor of the QuickJournal:
...
- Move it to it's own package org.apache.activemq.store.quick
- Brought in all the latest JournalPersistenceAdaptor enhancements
- It now uses the AsyncDataManager as the Journal implemenation which has better read performance
- Instead of forcing all PersistenceAdaptors to support external references, we now move all the message reference methods to a new set of interface class (MesageReferenceAdaptor)
- Enhanced a few Kaha container classes so that they take advantage of Generics
- Added a Kaha based MesageReferenceAdaptor impementation
- Strategy for deleting old journal log files is now in place so that disk space can be reclaimed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@492373 13f79535-47bb-0310-9956-ffa450edef68
2007-01-04 00:57:03 +00:00
61d56b290a
in stop() remove VMTransports after services stopped - to avoid a timing issue with
...
discovery spinning up a new instance
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491856 13f79535-47bb-0310-9956-ffa450edef68
2007-01-02 17:13:54 +00:00
81c5b1500b
in stop() remove VMTransports after services stopped - to avoid a timing issue with
...
discovery spinning up a new instance
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491794 13f79535-47bb-0310-9956-ffa450edef68
2007-01-02 13:39:10 +00:00
4cd0a27f91
Fix for https://issues.apache.org/activemq/browse/AMQ-1110
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491753 13f79535-47bb-0310-9956-ffa450edef68
2007-01-02 07:06:39 +00:00
3070d33275
Wait the perfect amount of time by using count down latches.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491455 13f79535-47bb-0310-9956-ffa450edef68
2006-12-31 17:33:56 +00:00
a810f4300a
Fix RecoveryBrokerTest that I messed up :)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491452 13f79535-47bb-0310-9956-ffa450edef68
2006-12-31 17:32:40 +00:00
b91103a830
sp mistake in log
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491432 13f79535-47bb-0310-9956-ffa450edef68
2006-12-31 15:36:43 +00:00
6ddeac7bc0
check we are not a slaveBroker() when dispatching
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491431 13f79535-47bb-0310-9956-ffa450edef68
2006-12-31 15:35:38 +00:00
7695676339
Fix for CursorDurableTest.
...
The TopicStorePrefetch was iterating items that were in the subscription but not added to the pending list.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491346 13f79535-47bb-0310-9956-ffa450edef68
2006-12-30 23:49:03 +00:00
2a682e2fb2
Applied patch from: https://issues.apache.org/activemq/browse/AMQ-961
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491185 13f79535-47bb-0310-9956-ffa450edef68
2006-12-30 07:27:06 +00:00
7351c4bd0d
clear batch entry if no more messages in the container
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491184 13f79535-47bb-0310-9956-ffa450edef68
2006-12-30 07:25:03 +00:00
fe3f492321
fixed class cast exception
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491128 13f79535-47bb-0310-9956-ffa450edef68
2006-12-29 23:01:39 +00:00
71e44ce436
put back using kaha as persistent adaptor
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491093 13f79535-47bb-0310-9956-ffa450edef68
2006-12-29 20:27:00 +00:00
3d0191e29e
clear batch entry if no more messages in the container
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491092 13f79535-47bb-0310-9956-ffa450edef68
2006-12-29 20:25:58 +00:00
8bc7f8636c
clear batch entry if no more messages in the container
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491090 13f79535-47bb-0310-9956-ffa450edef68
2006-12-29 20:24:11 +00:00
cd687e389c
clear last batch id if no more messages left to dispatch to a durable subscriber
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491089 13f79535-47bb-0310-9956-ffa450edef68
2006-12-29 20:21:10 +00:00
8b0f88a257
put the synchronization back for now
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@491088 13f79535-47bb-0310-9956-ffa450edef68
2006-12-29 20:19:25 +00:00
d7a9feb0a6
Fix for http://issues.apache.org/activemq/browse/AMQ-1113
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490967 13f79535-47bb-0310-9956-ffa450edef68
2006-12-29 09:28:01 +00:00
d2e606208d
Use the store based cursor by default for Queues - which will enable very large queue support
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490814 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 21:03:53 +00:00
6964747912
updated recoverNextMessages()
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490813 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 21:02:44 +00:00
a70f96bd37
set the basedir property - so can be run from inside eclipse
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490808 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 21:01:21 +00:00
63d78acccc
tidy up the tests
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490807 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 21:00:36 +00:00
81920f61cc
setPersistent() call has no affect when using XBeanBrokerFactory - start is already called
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490805 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 21:00:05 +00:00
17f8a7ebcc
use memory based persistence for this test
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490804 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:58:36 +00:00
710e2fd8eb
exclude TwoBrokerMulitcastQueueTest for now
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490802 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:58:00 +00:00
5b33fefd41
persistent not used - but needs to be set in config - as only has affect before
...
start is called on the broker (which happens automatically via afterPropertiesSet())
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490800 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:57:17 +00:00
974ec34df5
add a little more stress to the testManyProducersManyConsumers() test
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490798 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:55:56 +00:00
e5efc58cd4
Added support for hasMessagesToDeliver() method
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490796 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:52:41 +00:00
4a16f4527a
Transactions, when recovered, need to be recovered in prepare order:
...
a) order determined by an unsorted map iterator might confuse people
b) brokerSequence can get out of step for messages recovered then committed - e.g.
recovery on startup
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490795 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:51:22 +00:00
b1c94aa00b
Provide a more robust implementation, and one that deletes messages after they have been consumed
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490794 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:50:04 +00:00
3093ea0f6e
Transactions, when recovered, need to be recovered in prepare order:
...
a) order determined by an unsorted map iterator might confuse people
b) brokerSequence can get out of step for messages recovered then committed - e.g.
recovery on startup
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490792 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:48:04 +00:00
27ded73ca6
drop synchronization from connectionState and connection context -
...
not required when using ConcurrentHashMap and limited concurrency for
publishers or transactions for the same client connection
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490789 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:44:59 +00:00
bc03f37ebe
Fix for http://issues.apache.org/activemq/browse/AMQ-841
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490786 13f79535-47bb-0310-9956-ffa450edef68
2006-12-28 20:29:34 +00:00
63ec479423
forgot to remove the sophisticated debuging code - oops
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490454 13f79535-47bb-0310-9956-ffa450edef68
2006-12-27 07:43:43 +00:00
de64939643
somehow, somewhere, the ResponseCorrelator got dropped from the transport used by the
...
MasterBroker - so I've added it back here
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490452 13f79535-47bb-0310-9956-ffa450edef68
2006-12-27 07:40:13 +00:00
ef0b33eeb6
uses cases submitted by Brian Diesenhaus
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490319 13f79535-47bb-0310-9956-ffa450edef68
2006-12-26 16:14:14 +00:00
e6a418b13b
check we don't through null pointer exceptions - as this can lead to stack overflows ...
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490174 13f79535-47bb-0310-9956-ffa450edef68
2006-12-25 21:05:57 +00:00
c651ace525
it's ensure dispatching happens in order
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490111 13f79535-47bb-0310-9956-ffa450edef68
2006-12-25 07:19:29 +00:00
d8674a0fed
fix for http://issues.apache.org/activemq/browse/AMQ-1108
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@490007 13f79535-47bb-0310-9956-ffa450edef68
2006-12-24 08:57:34 +00:00
3be0113228
exclude QuickJournalXARecoveryBrokerTest
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@489769 13f79535-47bb-0310-9956-ffa450edef68
2006-12-22 21:22:42 +00:00
2b903d446a
Fix for AMQ-1106: PooledBrokerFactoryBean incorrectly compares broker config resources
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@489413 13f79535-47bb-0310-9956-ffa450edef68
2006-12-21 17:17:19 +00:00
958c41a12b
stop destinations when stoping a region
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@488958 13f79535-47bb-0310-9956-ffa450edef68
2006-12-20 08:33:50 +00:00
f6972ec84a
remove println messages from remove()
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@488783 13f79535-47bb-0310-9956-ffa450edef68
2006-12-19 19:41:41 +00:00
419ed2ee91
Patch for AMQ-1093 to avoid a deadlock if the transport is being reconnected from inside a MessageListener which is calling a send(), lets make the explicit clear of the consumer dispatch list asynchronous and within the existing mutex
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@487235 13f79535-47bb-0310-9956-ffa450edef68
2006-12-14 15:23:47 +00:00
e500f2ecc4
synchronize around the send on a Message
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@487232 13f79535-47bb-0310-9956-ffa450edef68
2006-12-14 15:18:25 +00:00
87d15d6b98
https://issues.apache.org/activemq/browse/AMQ-1097
...
- Fix for selector configured using destination options is not set
- Test case to demonstrate issue
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@487187 13f79535-47bb-0310-9956-ffa450edef68
2006-12-14 12:25:49 +00:00
747acfef69
Fix exception when removing message from MemoryMessageStore
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@486382 13f79535-47bb-0310-9956-ffa450edef68
2006-12-12 22:46:51 +00:00
16546f951a
added fix for https://issues.apache.org/activemq/browse/AMQ-908
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@486131 13f79535-47bb-0310-9956-ffa450edef68
2006-12-12 13:19:03 +00:00
870401217a
AMQ-1084: Allow o.a.a.pool to support XA transactions
...
Also enhance the pooled ConnectionFactory to reuse several connections.
Fix the lastUsed timestamp on the ConnectionPool to avoid discarding reusable connections.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@481742 13f79535-47bb-0310-9956-ffa450edef68
2006-12-03 09:24:55 +00:00
f1a989da9e
sp mistake
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480925 13f79535-47bb-0310-9956-ffa450edef68
2006-11-30 13:47:48 +00:00
415d46cf46
log which Persistence Adaptor we are using
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480924 13f79535-47bb-0310-9956-ffa450edef68
2006-11-30 13:46:08 +00:00
a9d1f21c05
http://jira.activemq.org/jira/browse/AMQ-583
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480854 13f79535-47bb-0310-9956-ffa450edef68
2006-11-30 06:33:50 +00:00
4597dddf79
Setting the Store based cursor as the default for Durable Subscribers
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480731 13f79535-47bb-0310-9956-ffa450edef68
2006-11-29 22:09:33 +00:00
789d4e5541
Fix for http://issues.apache.org/activemq/browse/AMQ-1078
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480717 13f79535-47bb-0310-9956-ffa450edef68
2006-11-29 21:26:23 +00:00
346119bfc4
applied patch for http://issues.apache.org/activemq/browse/AMQ-908
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480575 13f79535-47bb-0310-9956-ffa450edef68
2006-11-29 14:08:36 +00:00
d871d0e304
ensure container is initialized before accessing
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480416 13f79535-47bb-0310-9956-ffa450edef68
2006-11-29 05:36:42 +00:00
5c587a2f13
Ensure store is properly deleted, even if not initialized
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480185 13f79535-47bb-0310-9956-ffa450edef68
2006-11-28 20:08:26 +00:00
ed1537b79d
Added support for JDBC Master Slave for MySQL for AMQ-1074 thanks to the kind patch from Steve Lotito
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@480072 13f79535-47bb-0310-9956-ffa450edef68
2006-11-28 14:47:05 +00:00
935fde0377
added a test case to try reproduce bug AMQ-1054 (unfortunately it doesnt) - also added a patch to try fix AMQ-1054 based on the kind suggestion from Shoaib Akhtar that it could be the cast from getData() causing the ClassCastException; so AMQ-1054 may be fixed but as yet we don't have a test case to prove it
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479726 13f79535-47bb-0310-9956-ffa450edef68
2006-11-27 19:01:37 +00:00
4f7aeecc1e
added support for AMQ-1073 to allow selectors to be used with virtual destinations
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479694 13f79535-47bb-0310-9956-ffa450edef68
2006-11-27 17:16:33 +00:00
e78e72f957
updates for http://issues.apache.org/activemq/browse/AMQ-795
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479639 13f79535-47bb-0310-9956-ffa450edef68
2006-11-27 14:35:34 +00:00
a11060452b
support for durable store cursors and retroactive subscribers
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479614 13f79535-47bb-0310-9956-ffa450edef68
2006-11-27 13:40:11 +00:00
ec63977e81
Tidied up locking around cursor iterators
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479156 13f79535-47bb-0310-9956-ffa450edef68
2006-11-25 17:58:41 +00:00
6e3bb5d682
Moved the new JPA module to it's own directory.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479145 13f79535-47bb-0310-9956-ffa450edef68
2006-11-25 16:56:12 +00:00
9359e9f6ca
Update to fix http://issues.apache.org/activemq/browse/AMQ-791
...
Use in mmeory list in FilePendingMessageCursor - until memory limit reached - then use disk.
USe FilePendingMessageCursor in TopicSubscription instead of LinkedList
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479094 13f79535-47bb-0310-9956-ffa450edef68
2006-11-25 07:10:17 +00:00
118c806907
Added a new org.apache.activemq.kaha.impl.asyc package that holds data manager/journal that implements both the Kaha DataManager and ActiveIO Journal interfaces.
...
- Initial bench marks show it to be as fast or faster than the default ActiveIO Journal.
- The bigest differentiator is that this implementation of the journal was built to also provide fast reads.
- The DataManager interface was extracted and now the KahaStore can switch between the original DataManager implementation and the new implementation in the kaha.impl.async packagge.
- Simplified the original implementation by removing the AsyncDataWriters stuff since this is largely what the new package is based on.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@479089 13f79535-47bb-0310-9956-ffa450edef68
2006-11-25 06:00:56 +00:00
3bf0245e76
implementation of store based cursors for Queues and Durable Subscribers,
...
to fix:
http://issues.apache.org/activemq/browse/AMQ-845
http://issues.apache.org/activemq/browse/AMQ-1062
http://issues.apache.org/activemq/browse/AMQ-1061
http://issues.apache.org/activemq/browse/AMQ-493
http://issues.apache.org/activemq/browse/AMQ-914
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478967 13f79535-47bb-0310-9956-ffa450edef68
2006-11-24 19:57:51 +00:00
be6fac15e2
setter for max duration
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478598 13f79535-47bb-0310-9956-ffa450edef68
2006-11-23 15:30:34 +00:00
d81997d3eb
AMQ-526: get TwoBrokerMulticastQueueTest to work.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478558 13f79535-47bb-0310-9956-ffa450edef68
2006-11-23 13:07:33 +00:00
e00678027f
support for different message storage cursor types for Queue destination policies
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478509 13f79535-47bb-0310-9956-ffa450edef68
2006-11-23 08:19:00 +00:00
9e02c22529
Removed unnecessary System.out
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478325 13f79535-47bb-0310-9956-ffa450edef68
2006-11-22 21:21:02 +00:00
eb827e2780
Added a fix for AMQ-1068 to avoid lots of RAM being used up with deeply nested topic hierarchies - we basically create the AnyChild nodes on demand now rather than up front
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478324 13f79535-47bb-0310-9956-ffa450edef68
2006-11-22 21:19:21 +00:00
41b9089ac3
check messageId isn't null before trying to copy it
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478292 13f79535-47bb-0310-9956-ffa450edef68
2006-11-22 19:16:52 +00:00
5e1da9a9a6
Ensure clear all containers - not just active ones
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478262 13f79535-47bb-0310-9956-ffa450edef68
2006-11-22 18:06:24 +00:00
e78a6f7ee9
added yield back into dispatch() - but with a counter - so not so much of a performance hog
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478238 13f79535-47bb-0310-9956-ffa450edef68
2006-11-22 16:59:26 +00:00
e34cbc1b07
applied patch for http://issues.apache.org/activemq/browse/AMQ-1029
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477570 13f79535-47bb-0310-9956-ffa450edef68
2006-11-21 08:15:10 +00:00
878b9645ce
Updated Rapid Persistence Adaptor to do batching for cursors
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477567 13f79535-47bb-0310-9956-ffa450edef68
2006-11-21 08:11:03 +00:00
ecb50234ec
http://issues.apache.org/activemq/browse/AMQ-1042
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477356 13f79535-47bb-0310-9956-ffa450edef68
2006-11-20 21:40:28 +00:00
0607226831
Added the initial cut of a JPA based message store.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477273 13f79535-47bb-0310-9956-ffa450edef68
2006-11-20 18:13:50 +00:00
ea66d50338
Output the # of producers and consumers running in perf test
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477272 13f79535-47bb-0310-9956-ffa450edef68
2006-11-20 18:10:48 +00:00
7dde85b821
applied patch for http://issues.apache.org/activemq/browse/AMQ-959
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477171 13f79535-47bb-0310-9956-ffa450edef68
2006-11-20 13:41:40 +00:00
5367f1ecb0
fixed some timing issues using the Kaha Persistence Adaptor
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477166 13f79535-47bb-0310-9956-ffa450edef68
2006-11-20 13:11:26 +00:00
b02ca01826
applied patch for http://issues.apache.org/activemq/browse/AMQ-1006
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@477066 13f79535-47bb-0310-9956-ffa450edef68
2006-11-20 06:20:12 +00:00
979c5d55ee
applied patch for http://issues.apache.org/activemq/browse/AMQ-967
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476523 13f79535-47bb-0310-9956-ffa450edef68
2006-11-18 13:35:51 +00:00
97d0a61057
switch from using the RecordLocation interface to the Location interface since the adapter will need to
...
be aware of what log file the active records are in so that it can delete un-used log files.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476310 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 20:53:42 +00:00
ab66037b12
A simple test to allow profiler to get an idea of how much memory is allocated per
...
temporary Queue. It appears that the ConsumerAdvisory - one for each Connection, holds
a copy of every temporary Queue in the system.
I don't think this is a big issue - unless - as in this case - all the connections and the
broker are in the same jvm.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476299 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 20:23:54 +00:00
51e6a0d593
Made PerfRate a more thread safe.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476297 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 20:17:15 +00:00
5f68126945
sbe in dumpProducerRate()
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476294 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 20:10:34 +00:00
d47855ace3
added ability to have the consumer slow down. also better rate info.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476279 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 19:48:47 +00:00
87f2f502d7
enabled asyn sends.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476266 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 19:23:08 +00:00
f9a159723c
set the checkpoint workers to 1
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476265 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 19:22:39 +00:00
411e750806
added some comments about what we should problably do...
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476262 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 19:17:59 +00:00
94f16ac6ab
Adding a perf test that uses the journal kaha combination.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476255 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 18:59:58 +00:00
f65acf552b
force the datafile before it is removed so that all async writes are completed before the file handle is closed.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476225 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 17:30:53 +00:00
57a4071d94
Better.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476198 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 16:29:35 +00:00
e0fdce4f01
Ehanced these performance tests so that the producers are running in their own threads.
...
Also change the dumping of stats to be time based and not based on the number of messages received.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476189 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 16:04:57 +00:00
629bc81fb2
Adding persitent cursor support for Queues
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476101 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 10:33:57 +00:00
3b28c7c3ec
tightened up synchronization around dispatching
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476100 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 10:29:23 +00:00
9dcd00823b
applied patch for http://issues.apache.org/activemq/browse/AMQ-1010
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476099 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 10:24:04 +00:00
e582e2fd40
only rotate consumers if there are consumers to rotate!
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476093 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 09:48:27 +00:00
69e5439718
More Java 5 Ehancements.
...
- Use activeio-3.1 snapshot since that has been upgraded to Java 5
- Don't need mx4j since Java 5 includes a JMX server
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476007 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 00:56:16 +00:00
86cbdfd5db
Switching to Java 5.. Build and Runtime now require Java 5 see: http://www.nabble.com/Switching-to-ActiveMQ-4.2-to-Java-5----tf2637427.html
...
- Update maven build
- Removed dependency on concurrent-backport
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475999 13f79535-47bb-0310-9956-ffa450edef68
2006-11-17 00:29:03 +00:00
849d2f330e
The async writer is now working and enabled by default.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475943 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 22:06:22 +00:00
a58d36b9b3
see: http://issues.apache.org/activemq/browse/AMQ-1056
...
We now expire messages on the broker.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475848 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 18:24:14 +00:00
4f3f52392d
Started on an AsyncDataFileWriter implementation so that we can get more concurrent writes and batch up
...
file sync() calls done.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475775 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 15:37:35 +00:00
822df45e38
Rev up openwire version in case someone makes changes
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475773 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 15:35:24 +00:00
86faaef7c9
Fix for AMQ-1053. Added support for pluggable message transformation together with an implementation using XStream to marshall ObjectMessage instances as TextMessages. See the XStreamTransformTest to see how a producer can send ObjectMessages but then consumers can see either ObjectMessages or TextMessages depending on their requirements.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475701 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 12:08:22 +00:00
34fb326a0a
added test case for AMQ-1027
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475680 13f79535-47bb-0310-9956-ffa450edef68
2006-11-16 10:56:07 +00:00
fc6ab9c687
change Queue message store in Kaha store adaptor to use memory efficent list instead
...
of Map containers
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475416 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 20:56:21 +00:00
ba476b36f0
Setting some svn eol-styles and improving source distro assembly
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475265 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 15:43:24 +00:00
940850910d
added a simple command agent that can be used to send messages to a destination (ActiveMQ.Agent) to interact with the broker via the activemq-console commands (list, query, browse etc)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@475210 13f79535-47bb-0310-9956-ffa450edef68
2006-11-15 12:02:34 +00:00
06a365f12c
Setting svn:eol-style
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474985 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:16:11 +00:00
9e6eb830b3
Set the eol-style
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474977 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 21:02:18 +00:00
ae5cf8ef9e
https://issues.apache.org/activemq/browse/AMQ-1016
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474872 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 17:11:37 +00:00
c0bc3e00c1
http://issues.apache.org/activemq/browse/AMQ-1045 we now evict failed connections from a connection pool.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474799 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 14:12:03 +00:00
caa30ffdc0
Added synconization to the methods that setup connection state so that when an async error is detected, it properly does a full cleanup. Previously subscriptions were not properly cleaned up since they were being setup at the same time as they were being cleaned up.
...
Also start 1 async exception thread ever since an async exception leads to connection tear down. Subsequent failures do not need additional async threads started.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474769 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 12:44:16 +00:00
7a3de7693b
log the the exception if an exception caught in rotating the consumers
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474674 13f79535-47bb-0310-9956-ffa450edef68
2006-11-14 06:27:34 +00:00
6895d009d8
Split the internal messages in a Queue destination in two - messages accessed by the
...
PendingMessageCursor and work in progress or pagedInMessages - which are instances
of QueueMessageReference - hence keeping the semantics for Message Groups etc. and keeping
the majority of the 'fiddly bits' intact.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474475 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 20:06:49 +00:00
55f4aad761
check that Queue messages aren't acknowledged before applying a filter
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474469 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:54:40 +00:00
9fcfa5c6d2
remove RangeLimitedMap - will be replaced with B+ Tree
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474468 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:52:47 +00:00
6b5840f8c1
remove RangeLimitedMap - will be replaced with B+ Tree
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474467 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:51:38 +00:00
b376ce24ef
propagate exceptions up to the caller
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474466 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:50:31 +00:00
43d2ef0469
log an error for ConnectionErrors that are not transport or
...
Broker in shutdown related
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@474465 13f79535-47bb-0310-9956-ffa450edef68
2006-11-13 19:49:33 +00:00
2510b088ad
fixed for http://issues.apache.org/activemq/browse/AMQ-1042
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473647 13f79535-47bb-0310-9956-ffa450edef68
2006-11-11 06:09:59 +00:00
beaca8a043
Fix some failing test cases in windows.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473224 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 07:29:23 +00:00
a8f4f6978c
Added optimization to determine the highest priority consumer during addition of subscription.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473223 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 07:28:27 +00:00
8951023556
https://issues.apache.org/activemq/browse/AMQ-1024
...
- Fix case where a non-exclusive consumer registered first will receive a message, before an exclusive consumer.
- Added junit test case to demonstrate the issue.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473219 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 07:16:25 +00:00
d71bc421f8
We should let a client change the client id on a connection even if it was set on the connection factory.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@473167 13f79535-47bb-0310-9956-ffa450edef68
2006-11-10 02:04:40 +00:00
8be1b5eb5a
Reving up version
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472518 13f79535-47bb-0310-9956-ffa450edef68
2006-11-08 15:27:38 +00:00
4b5bc5eb2d
added synchronization around marshal/unmarshal
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472421 13f79535-47bb-0310-9956-ffa450edef68
2006-11-08 08:23:08 +00:00
da5139c24b
All message dispatching should occur from the session's executor. Also, we should dispatch any messages in the consumers queue before dispatching messages in the session's queues.
...
http://issues.apache.org/activemq/browse/AMQ-1031
http://issues.apache.org/activemq/browse/AMQ-1032
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472345 13f79535-47bb-0310-9956-ffa450edef68
2006-11-08 00:14:56 +00:00
c636b3798f
Added test case to test resizing of internal buffer of DataByteArrayOutputStream.
...
Fix bug during resizing of internal buffer of DataByteArrayOutputStream.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472258 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 21:00:46 +00:00
0c93dfde72
Added message ordering assertions and also a test case that uses consumer.receive() instead of a messsage listener
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472237 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 20:30:37 +00:00
11501cb38e
removed java 5 annotations :)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472209 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 19:12:48 +00:00
39b0376001
added a test case to reproduce a bad ack bug
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472207 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 19:10:01 +00:00
3daf923b51
Added some fields for future use to the BrokerInfo and ProducerInfo classes.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472165 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 16:56:12 +00:00
da7478d9d5
Eliminated AbstractConnection by inlining it into TransportConnection. The synchronization complexity between the two was making my head spin. Now that they are consolidated, we can try to simply them a little more.
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@472157 13f79535-47bb-0310-9956-ffa450edef68
2006-11-07 16:40:23 +00:00
cafe4cbcc4
http://issues.apache.org/activemq/browse/AMQ-1026
...
Created a ReconnectTest that showed problems with the synchronization used when a client reconnects to a server via failover before the server detects the client failure.
- InactivityMonitor : Better syncronization so that an inactivty exception is only raised once.
- Connection: Added serviceExceptionAsync() method and change all methods that are dispatching to use this instead of serviceException() to avoid possible deadlock that can occur during connection shutdown.
- MockTransport: finer grained sychonization to avoid deadlocks.
- PrefetchSubscription: it is possible it will get duplicate acks on a failover reconnect
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@471837 13f79535-47bb-0310-9956-ffa450edef68
2006-11-06 19:35:59 +00:00
36de58b371
fix for https://issues.apache.org/activemq/browse/AMQ-1023
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470695 13f79535-47bb-0310-9956-ffa450edef68
2006-11-03 07:15:37 +00:00
4821b9da70
Use Input/Output Stream intefaces instead of concrete classes
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470398 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:49:58 +00:00
8a8f41c33b
Added test to make sure ConnectionFactory is serializable - which
...
is a requirement of the JMS spec
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470395 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:47:46 +00:00
ae687a1182
moved StoreByteArray stream methods to util
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470391 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:36:21 +00:00
166a04bc58
make size of io buffers configurable
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470390 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:35:46 +00:00
fdcc973923
optimized
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470389 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:34:53 +00:00
330e73140a
moved utility methods for reading byte streams to utils package from Kaha
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470388 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:34:22 +00:00
526cb5bae8
make enabling statistics configurable
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470387 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 15:33:25 +00:00
12fff78943
fixed typo
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@470282 13f79535-47bb-0310-9956-ffa450edef68
2006-11-02 08:57:54 +00:00
3f74b0e1c0
support for ByteSequence
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469986 13f79535-47bb-0310-9956-ffa450edef68
2006-11-01 17:13:39 +00:00
b3e315fcc2
disabled the use of the CommandAgent by default to avoid causing the VM broker to keep around forever (since the broker itself creates a VM transport which avoids it ever being closed)
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469972 13f79535-47bb-0310-9956-ffa450edef68
2006-11-01 16:37:39 +00:00
b93cd9ec13
Ensure Administered objects are Serializable
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469873 13f79535-47bb-0310-9956-ffa450edef68
2006-11-01 11:47:51 +00:00
49e10d36fc
added support for a simple message based command agent so that you can send management commands to the broker over JMS
...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@469135 13f79535-47bb-0310-9956-ffa450edef68
2006-10-30 12:17:14 +00:00
James Strachan
Hiram R. Chirino
Robert Davies
Jonas B. Lim
Adrian T. Co
Guillaume Nodet
Frederick G. Oconer