Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-19 00:21:25 +00:00
Code Issues Packages Projects Releases Wiki Activity
2,230 Commits 22 Branches 100 Tags
Commit Graph

1340 Commits

Author SHA1 Message Date
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
Robert Davies
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
James Strachan
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
James Strachan
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
Jonas B. Lim
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Jonas B. Lim
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
Robert Davies
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
Robert Davies
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
James Strachan
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
Robert Davies
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
Hiram R. Chirino
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
James Strachan
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Hiram R. Chirino
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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