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

1330 Commits

Author SHA1 Message Date
Robert Davies
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
Robert Davies
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
Robert Davies
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Robert Davies
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Hiram R. Chirino
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
Hiram R. Chirino
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
Robert Davies
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
Robert Davies
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
Hiram R. Chirino
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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
Robert Davies
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