5ac6f3a890
removed System.out
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583571 13f79535-47bb-0310-9956-ffa450edef68
2007-10-10 18:28:53 +00:00
b2f7ba79db
add some more useful methods
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583237 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 17:45:54 +00:00
5dcf9cf6b9
added a plugin to support invocation of MessageListener classes as a bean in Camel; for more information see: http://cwiki.apache.org/CAMEL/activemq.html
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583185 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 14:44:50 +00:00
810375af5f
added a plugin to support invocation of MessageListener classes as a bean in Camel; for more information see: http://cwiki.apache.org/CAMEL/activemq.html
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583184 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 14:44:20 +00:00
48e8c053fc
updated javadoc link
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583163 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 13:35:57 +00:00
27a6c0a301
updated the javadoc to be more clear about the camel support
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@583114 13f79535-47bb-0310-9956-ffa450edef68
2007-10-09 11:28:38 +00:00
b9d0972596
quick fix for npe
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582910 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 17:47:47 +00:00
22fbb80daf
make persistentIndex true by default
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582839 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 15:10:19 +00:00
edb50cb4de
set options on the discovery agent correctly from the URI
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582810 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 12:54:35 +00:00
d1eb18af70
Add properties to the AMQPersistenceAdaptorFactory
...
to set syncOnWrite(default=false) and persistentIndex(default=true) properties
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582801 13f79535-47bb-0310-9956-ffa450edef68
2007-10-08 12:39:48 +00:00
1d487896b4
refresh entry for prev as well as next
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582575 13f79535-47bb-0310-9956-ffa450edef68
2007-10-07 05:10:28 +00:00
84a116d2c7
Fix for https://issues.apache.org/activemq/browse/AMQ-1445
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582574 13f79535-47bb-0310-9956-ffa450edef68
2007-10-07 04:42:24 +00:00
e2ef8b8165
patch http://issues.apache.org/activemq/browse/AMQ-1444
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@582086 13f79535-47bb-0310-9956-ffa450edef68
2007-10-05 06:02:46 +00:00
f3d633c2a9
Test case for sending single messages per connection - was blowing memory - now fixed
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581885 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 13:01:25 +00:00
805a0cc506
the MESSAGE_SIZE_OVERHEAD was too low - increased it to a more realistic size
...
Please note - this is related to the overhead in broker memory - not
the on-the-wire size - which is small
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581882 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 12:49:37 +00:00
5f8c101973
By default, use no subscription recovery policy for temporary or advisory topics
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581881 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 12:48:02 +00:00
fc69b29343
handle errors from recovery check gracefully
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581792 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 08:00:39 +00:00
3c1a8474f9
FilePendingMessageCursor was being added twice to the MemoryUsage
...
which resulted in a memory leak
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581784 13f79535-47bb-0310-9956-ffa450edef68
2007-10-04 06:18:49 +00:00
c256dcf9e8
Fix for https://issues.apache.org/activemq/browse/AMQ-1038
...
We now send REDELIVERY acks to the broker when a message is redelivered. This allows the broker to update the message with the number of times redelivery has occured so that if the message is delivered to another consumer it can DQL the message when max redeliveries have occured across consumers.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581747 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 23:32:29 +00:00
1401e69956
after canceling a TimerTask - purge from the Timer list - fix memory leak
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581736 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 21:55:40 +00:00
7b1fd3484e
Fix for http://issues.apache.org/activemq/browse/AMQ-1250
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581715 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 20:24:27 +00:00
08841bbde3
fix memory leak in ActiveMQConnection - with asyncConnectionThread not being shutdown on a close
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581683 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 18:50:03 +00:00
5bd3bf6e24
Ignore NULL references when checking isEmpty
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581568 13f79535-47bb-0310-9956-ffa450edef68
2007-10-03 11:24:38 +00:00
69a5e00843
be conservative allocating objects up-front
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581321 13f79535-47bb-0310-9956-ffa450edef68
2007-10-02 17:58:11 +00:00
595d95b3da
Have the TransactionContext per connection
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581242 13f79535-47bb-0310-9956-ffa450edef68
2007-10-02 13:58:22 +00:00
6aa4bcad5b
some unnecessary memory allocations removed
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581167 13f79535-47bb-0310-9956-ffa450edef68
2007-10-02 09:25:39 +00:00
53c4e125f6
Fix for AMQ-1095:
...
- Added contributed test cases
- We now filter out non-matching messages as they are loaded into the TopicStorePrefetch
- Changed the TopicStorePrefetch and StoreDurableSubscriberCursor so that they don't depend
on the pending message counter since some stores cannot give an accurate count for it.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@581053 13f79535-47bb-0310-9956-ffa450edef68
2007-10-01 20:02:18 +00:00
7bd8fb6754
Fix failing test cases.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@580475 13f79535-47bb-0310-9956-ffa450edef68
2007-09-28 20:16:08 +00:00
3d024d6b4f
Make amq 5.x compatible again with 4.x clients
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@580382 13f79535-47bb-0310-9956-ffa450edef68
2007-09-28 15:09:33 +00:00
19a83ae3cb
Rolled back patches for https://issues.apache.org/activemq/browse/AMQ-1361 - as no licence headers where provided - we can't accept
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@580273 13f79535-47bb-0310-9956-ffa450edef68
2007-09-28 09:46:50 +00:00
e21587fb9e
Added the ASL to a bunch of property files.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@580013 13f79535-47bb-0310-9956-ffa450edef68
2007-09-27 13:35:43 +00:00
42b768aa1f
added patch for https://issues.apache.org/activemq/browse/AMQ-1435 to handle Mirrored Queues (so that folks can consume on a topic what messages are sent to a queue)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@579941 13f79535-47bb-0310-9956-ffa450edef68
2007-09-27 08:26:57 +00:00
8cad176f68
minor change to make tests more exclusive to avoid 'em hitting each other
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@579639 13f79535-47bb-0310-9956-ffa450edef68
2007-09-26 12:30:45 +00:00
d48322690f
added patch for AMQ-1434 to allow transport listeners to be used with a connection factory for easy integration with Spring JmsTemplate etc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@579498 13f79535-47bb-0310-9956-ffa450edef68
2007-09-26 08:08:14 +00:00
2b063efafa
fix reference counting
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@578877 13f79535-47bb-0310-9956-ffa450edef68
2007-09-24 17:00:08 +00:00
01bdc524e7
Better broker shutdown handling and also better test support.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577882 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 19:11:44 +00:00
b7b929d90f
Removing invalid testcase. This test was setting up 2 consumers and storing the message sequences in a single list for both. Further more it was checking that those messages were delivered in order. It is not possible garantee order between 2 consumers.. therefore this test is invalid.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577881 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 19:09:44 +00:00
c8666f89dc
Fix for broken test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577878 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 18:57:38 +00:00
54d24ad3bf
Fix broke test.. A transaction manager is now required when transacted endpoints are configured.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577869 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 18:49:01 +00:00
8032375531
AMQ-1429: Package ActiveMQ as OSGi bundles instead of plain jars
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577760 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 14:16:12 +00:00
00895cecc1
ActiveMQ is out of the incubator.. no need for DISCLAIMER.txt anymore
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577759 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 14:13:23 +00:00
4d01443fa7
make the locking more coarse grained
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577746 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 13:49:32 +00:00
417fcd7f19
Don't use System.out
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@577683 13f79535-47bb-0310-9956-ffa450edef68
2007-09-20 11:09:32 +00:00
6b7055afc8
remove unused imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@576527 13f79535-47bb-0310-9956-ffa450edef68
2007-09-17 17:06:14 +00:00
a98333a19a
use default amq persistence
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@574646 13f79535-47bb-0310-9956-ffa450edef68
2007-09-11 17:38:56 +00:00
696b34a01d
use the same ConnectionFactory so that transactional consume + send can use the same session
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@574465 13f79535-47bb-0310-9956-ffa450edef68
2007-09-11 05:47:30 +00:00
5829d7045c
added better debug logging
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@574460 13f79535-47bb-0310-9956-ffa450edef68
2007-09-11 05:20:20 +00:00
84da202a7a
Update to the latest version of xbean
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@574327 13f79535-47bb-0310-9956-ffa450edef68
2007-09-10 18:41:32 +00:00
a69c3e78c5
Switch to using a Timer to schedual tasks. Seems to have much more acurate time delays between executions.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@574321 13f79535-47bb-0310-9956-ffa450edef68
2007-09-10 18:27:40 +00:00
5f96839259
Moved the camel-activemq module into the activemq-core module to break the circular dependency between the activemq and camel projects.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573615 13f79535-47bb-0310-9956-ffa450edef68
2007-09-07 15:44:45 +00:00
b732d3d114
Fix for the QueueWorkerPrefetchTest. The VMPendingMessageCursor.isEmpty() was returning true when it had an a message that had been marked dropped due to it being delivered by another subscription.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573400 13f79535-47bb-0310-9956-ffa450edef68
2007-09-06 22:19:25 +00:00
222daf2323
Fix for https://issues.apache.org/activemq/browse/AMQ-1382 ... if the broker.persistent==false then we should not create any files, not even for the Temp Store.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573397 13f79535-47bb-0310-9956-ffa450edef68
2007-09-06 22:14:34 +00:00
b81dd2886e
Fixed ContainerId so that it also uses the container name when it compares equality. Switch back to using a single index file
...
for the topic susbcriptions lists.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573395 13f79535-47bb-0310-9956-ffa450edef68
2007-09-06 22:11:43 +00:00
838e9a42b4
if the container name has '/' in it then make sure we create the parent directories before we try to access the file.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573392 13f79535-47bb-0310-9956-ffa450edef68
2007-09-06 22:05:43 +00:00
1301501a0a
Fixed synchronizations so that threads don't block each others processing as much and now the test works fine without hanging. see https://issues.apache.org/activemq/browse/AMQ-1251
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573342 13f79535-47bb-0310-9956-ffa450edef68
2007-09-06 19:25:46 +00:00
642d38cd8c
Fix for https://issues.apache.org/activemq/browse/AMQ-1156
...
We now actually update the tcpNoDelay setting on the socket once the wireformat options are negociated. This allows
the client to control if his socket and the server's socket use the option. By default tcpNoDelay is enabled.
the client should use a URL like -Durl=tcp://localhost:61616?wireFormat.tcpNoDelayEnabled=false to disable tcpNoDelay on both the client and the server socket.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573080 13f79535-47bb-0310-9956-ffa450edef68
2007-09-05 21:51:40 +00:00
9e61ade946
Fixing compile issue cause by camel API change
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@573005 13f79535-47bb-0310-9956-ffa450edef68
2007-09-05 17:18:54 +00:00
65454017fc
Ensure system safe names are used for container names
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@572975 13f79535-47bb-0310-9956-ffa450edef68
2007-09-05 15:47:20 +00:00
0d0dd4587d
use potentially shorter container name for the topic subscriber references
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@572974 13f79535-47bb-0310-9956-ffa450edef68
2007-09-05 15:41:19 +00:00
ec2cfc5fd0
shorten the name of the container containing the SubscriberMessageList
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@572905 13f79535-47bb-0310-9956-ffa450edef68
2007-09-05 09:06:32 +00:00
1195ae751c
ensure the ConectionContext always has a broker set before sending message to DLQ
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@572300 13f79535-47bb-0310-9956-ffa450edef68
2007-09-03 12:50:17 +00:00
0a52fe7289
Satitized the filenames that the KahaStore uses.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@571306 13f79535-47bb-0310-9956-ffa450edef68
2007-08-30 20:49:41 +00:00
eba0ae3c7b
test case for https://issues.apache.org/activemq/browse/AMQ-1251
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@571150 13f79535-47bb-0310-9956-ffa450edef68
2007-08-30 12:54:06 +00:00
3cd1e6c73f
ensure exception is logged if one is raised sending a message to a dead letter queue
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@569270 13f79535-47bb-0310-9956-ffa450edef68
2007-08-24 06:29:18 +00:00
d97054b1c2
fix for https://issues.apache.org/activemq/browse/AMQ-1365
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@568869 13f79535-47bb-0310-9956-ffa450edef68
2007-08-23 07:48:37 +00:00
fba074227d
allow a MessageListener to be specified when creating a consumer; to avoid threading issues when creating lots of consumers after the connection has started
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@568644 13f79535-47bb-0310-9956-ffa450edef68
2007-08-22 15:09:44 +00:00
2b0024c269
Made the SystemUsage and associated *Usage classes IOC friendly so that they can be configured
...
via xbean/spring. Fixed the ConfigTest test case.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@567796 13f79535-47bb-0310-9956-ffa450edef68
2007-08-20 19:30:33 +00:00
6d8e2c5b3a
UpdateManager changed to account for Store and Temp data usage as well as memory usage
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@567647 13f79535-47bb-0310-9956-ffa450edef68
2007-08-20 10:37:29 +00:00
90deed42cc
Improved the STOMP test case a little to verify that killed stomp clients redeliver un acked messages
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@566277 13f79535-47bb-0310-9956-ffa450edef68
2007-08-15 17:33:05 +00:00
926f9ce614
Control file was not properly loading state when the the record length stored was not == to the max record length.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@566202 13f79535-47bb-0310-9956-ffa450edef68
2007-08-15 14:46:03 +00:00
232844d462
Removing unwanted test files from the test-jar
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@566121 13f79535-47bb-0310-9956-ffa450edef68
2007-08-15 12:34:24 +00:00
54c8eeb842
temporarily comment out log4j dependency
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@565632 13f79535-47bb-0310-9956-ffa450edef68
2007-08-14 06:07:37 +00:00
df6b54240c
Applied patch from http://issues.apache.org/activemq/browse/AMQ-1361
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@565381 13f79535-47bb-0310-9956-ffa450edef68
2007-08-13 15:44:44 +00:00
5f1adbe898
More checkstyle fixes
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564977 13f79535-47bb-0310-9956-ffa450edef68
2007-08-11 21:29:21 +00:00
933eb2f9e4
More checkstyle fixes and Generics usage.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564814 13f79535-47bb-0310-9956-ffa450edef68
2007-08-11 00:49:19 +00:00
5719351cb7
Fix for the testQueuePersistentUncommitedAcksLostOnRestart() test in RecoveryBrokerTest. Since this test resuses the memory based store instance across restarts, the cusror pointers were not getting reset after restart.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564685 13f79535-47bb-0310-9956-ffa450edef68
2007-08-10 17:18:14 +00:00
ecf89a60bf
More checkstyle violation fixes
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564679 13f79535-47bb-0310-9956-ffa450edef68
2007-08-10 16:57:01 +00:00
1963ea4006
added test case to simulate "javax.jms.JMSException: Transaction 'TX:ID:...' has not been started." exception
...
this test appears to manifest consistently on a MacBook. Haven't been able to reproduce this on windows though.
Is excluded by default as the test can sometime take too long to execute
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564505 13f79535-47bb-0310-9956-ffa450edef68
2007-08-10 08:22:09 +00:00
fc00993839
More checkstyle violation fixes
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564271 13f79535-47bb-0310-9956-ffa450edef68
2007-08-09 16:37:49 +00:00
74a7a8bbfc
More checkstyle fixes
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@564057 13f79535-47bb-0310-9956-ffa450edef68
2007-08-09 00:34:07 +00:00
f812e34179
More checkstyle fixes
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@563982 13f79535-47bb-0310-9956-ffa450edef68
2007-08-08 18:56:59 +00:00
43ba1be188
Fixing checkstyle issues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@563930 13f79535-47bb-0310-9956-ffa450edef68
2007-08-08 16:30:17 +00:00
230a86c489
Fixing a bunch of checkstyle violations
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@563921 13f79535-47bb-0310-9956-ffa450edef68
2007-08-08 15:52:25 +00:00
0945e32b6a
Fix the TopicMasterSlaveTest that was failing
...
- Stack was overflowing due to the advisory broker advising on topic advisories
- MasterConnector now makes sync request to the slave if it's given a sync request
- Test was failing due to kaha not being able to create a file that was too long.. fixed by making the
sub name and client id and dest name shorter. Need to revisit.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@563854 13f79535-47bb-0310-9956-ffa450edef68
2007-08-08 13:22:15 +00:00
4102accade
migrated the Camel destination code from the camel project into ActiveMQ as it makes more sense to host it here - and avoids a circular dependency issue when releasing ActiveMQ 5.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@563609 13f79535-47bb-0310-9956-ffa450edef68
2007-08-07 18:36:58 +00:00
2728ccbb88
Fix for AMQ-1356 : Durable Subscriptions do not work with Wildcards after broker is restarted.
...
- Added a RecoveryBrokerTest.testWildCardSubscriptionPreservedOnRestart() test case that was showing
that that wildcards did not work with DurableSubscriptions
- Fix the TransactedTopicMasterSlaveTest so that setDeleteAllMessagesOnStartup() takes effect (had to be done before the connectors are added.
- Change the MessageStore interface so that subscriptions are created using the data in the SubscriptionInfo class
- Added a subscribedDestination field to the SubscriptionInfo so that the original wildcard subscrption can be remembered
- The KahaReference store now deletes it's State store too when deleteAllMessages() is called
- Fixed KahaPersistenceAdapter.getDestinations() so that it actually returns all the destinations.
- We now recover all the topics eagerly when the topic region is started.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@563194 13f79535-47bb-0310-9956-ffa450edef68
2007-08-06 17:07:55 +00:00
8b68c62249
Switched from using ${activemq-version} to using ${version}
...
added a required dependency in activemq-web to spring-web
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@562099 13f79535-47bb-0310-9956-ffa450edef68
2007-08-02 13:03:33 +00:00
64b8fb64f4
Added explicit error for badly formated broker name
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561815 13f79535-47bb-0310-9956-ffa450edef68
2007-08-01 14:49:48 +00:00
ec6a7029c5
updated message properties
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561428 13f79535-47bb-0310-9956-ffa450edef68
2007-07-31 18:34:32 +00:00
5ad4732038
- Faster VMTransport shutdown by avoiding a potential deadlock
...
- Better connection shutdown.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561180 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 23:11:24 +00:00
f90c62c640
Fix for intermitent test failure at:
...
testOneProducerManyConsumersManyMessages(org.apache.activemq.broker.policy.RoundRobinDispatchPolicyTest)
It was checking that messages were evenly distributed accross consumers but that can only be garanteed when
the consumer prefetches can hold all the published messages.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561113 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 20:50:01 +00:00
350a2aad7f
Fix for https://issues.apache.org/activemq/browse/AMQ-1305
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561109 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 20:36:16 +00:00
c07b23352c
Fix for https://issues.apache.org/activemq/browse/AMQ-567
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561088 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 18:45:49 +00:00
b3eb9a5e5b
added support for properties brokerInTime and brokerOutTime
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561028 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 16:07:17 +00:00
a401575569
Added support for length of time messages are processed by the broker -
...
fix for https://issues.apache.org/activemq/browse/AMQ-1160 ,
https://issues.apache.org/activemq/browse/AMQ-1072 ,
https://issues.apache.org/activemq/browse/AMQ-936
and ground work for for https://issues.apache.org/activemq/browse/AMQ-567
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@561026 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 16:01:37 +00:00
b97f7d8479
Fixed pom so that it generates the openwire commands when mvn clean compile -P openwire-generate
...
is run
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560989 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 14:10:04 +00:00
2d27d56e59
- Fix for the xmpp transport needed du to recently added stop() synchronization.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560979 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 13:41:59 +00:00
ea74731701
Serveral changes needed to Fix https://issues.apache.org/activemq/browse/AMQ-1349
...
- The vm:// transport was delivering events to the listener before start() was called. Also clean it up a little by consolidating
the use of the prePeerSetQueue and messageQueue field.
- the tcp:// .stop() method now blocks until the thread that calls out to the listener is shutdown.
- TransportConnection was not doing a good job synchronizing when multiple concurrent conenctions to the same connection Id was established.
IllegalStateExceptions were common when a failover connection reconnected. Now we make sure that only 1 connection with a given connectionId
is activley operating in the broker. Also removed 1 un-needed hash lookup by replacing the brokerConnectionStates Map with the
connectionState variable.
Also added a pause in the JmsTempDestinationTest to avoid intermitent failures.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560872 13f79535-47bb-0310-9956-ffa450edef68
2007-07-30 05:34:37 +00:00
3a5f48d277
Fix for http://issues.apache.org/activemq/browse/AMQ-1080
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560783 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 19:01:29 +00:00
eeb8d5bafc
remove println
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560700 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 08:59:46 +00:00
13729a3690
Enabled
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560699 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 08:59:30 +00:00
6013b64f97
updated for junit test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560698 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 08:58:59 +00:00
35ba427ec9
Fix for http://issues.apache.org/activemq/browse/AMQ-920
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560696 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 08:57:31 +00:00
50c6d9ccc8
A message is a message isMessage()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560695 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 08:56:54 +00:00
14180c5cb3
check for nulls
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560694 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 08:56:21 +00:00
1e3e5b7223
Fix for http://issues.apache.org/activemq/browse/AMQ-1294
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560693 13f79535-47bb-0310-9956-ffa450edef68
2007-07-29 08:54:49 +00:00
3b73e60233
Fix for http://issues.apache.org/activemq/browse/AMQ-1348
...
Better file locking on windows. We now use a seperate lock file to signifiy the lock on the kaha db.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560352 13f79535-47bb-0310-9956-ffa450edef68
2007-07-27 18:49:47 +00:00
9d2e5418fe
Added a handy processingDelay option to the MessageIdList so that a test case and simulate a slow consumer
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560294 13f79535-47bb-0310-9956-ffa450edef68
2007-07-27 16:02:04 +00:00
d56ebd842d
fix for AMQ-1346.. moved handling the not full event into the queue's task runner to avoid deadlocks and the recursiveness of the pagIn call that was
...
causing the Illeagal state exception.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560282 13f79535-47bb-0310-9956-ffa450edef68
2007-07-27 15:42:31 +00:00
956fe93bd2
No need to create destination twice when doing a destination lookup
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@560274 13f79535-47bb-0310-9956-ffa450edef68
2007-07-27 15:29:51 +00:00
6a928d5cfe
- Made the dispatchValve handling a little safer.. it was previously possible that an exception could cause the broker to miss turning it off before trying to turn it on.
...
- better producer flow control logic, was not working for sync send producers without a window
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559915 13f79535-47bb-0310-9956-ffa450edef68
2007-07-26 18:07:16 +00:00
3b88ba0c47
Fix for AMQ-1344 - Deadlock can occur when cerating and deleting many destinations concurrently
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559155 13f79535-47bb-0310-9956-ffa450edef68
2007-07-24 18:27:49 +00:00
76b2a3ed8f
Fix for AMQ-1343 - Network conntions not shutdown propertly when a InvalidClientIDException occurs
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559139 13f79535-47bb-0310-9956-ffa450edef68
2007-07-24 17:51:32 +00:00
7c94a73ba6
Fix for AMQ-1342 - Added backoff delay in generating discovery events when broker failures are reported
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559132 13f79535-47bb-0310-9956-ffa450edef68
2007-07-24 17:43:26 +00:00
97a591f08f
Fix for AMQ-1341 - Improve the InvalidClientIDException message so that we know where the previous connection was established from.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559111 13f79535-47bb-0310-9956-ffa450edef68
2007-07-24 17:08:31 +00:00
5a3a45f0c0
Fix for AMQ-1340 - Thread gets stuck in a WAIT and never returns
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559092 13f79535-47bb-0310-9956-ffa450edef68
2007-07-24 16:19:43 +00:00
8f6fac7f1b
Fix for AMQ-1339 - Give the connection dispatcher threads names that are easy to associate with the peer.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@559071 13f79535-47bb-0310-9956-ffa450edef68
2007-07-24 15:01:32 +00:00
3a7c673dec
https://issues.apache.org/activemq/browse/AMQ-1337 - Broker should finish accepting connection in an async thread.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@558814 13f79535-47bb-0310-9956-ffa450edef68
2007-07-23 18:02:41 +00:00
20364163e9
applied patch for https://issues.apache.org/activemq/browse/AMQ-1254
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@558774 13f79535-47bb-0310-9956-ffa450edef68
2007-07-23 15:27:43 +00:00
6ce8c3bf87
AMQ-1335 - Exclusive consumers are now selected up front when the consumer gets registered.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@558767 13f79535-47bb-0310-9956-ffa450edef68
2007-07-23 15:09:28 +00:00
a414c20dcb
Fix for:
...
http://issues.apache.org/activemq/browse/AMQ-1207
http://issues.apache.org/activemq/browse/AMQ-880
http://issues.apache.org/activemq/browse/AMQ-450
http://issues.apache.org/activemq/browse/AMQ-879
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@558054 13f79535-47bb-0310-9956-ffa450edef68
2007-07-20 17:08:10 +00:00
cfdc5e3de3
fix null pointer in test case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@558052 13f79535-47bb-0310-9956-ffa450edef68
2007-07-20 17:03:39 +00:00
2d5bb84a47
Applying patch for http://issues.apache.org/activemq/browse/AMQ-1323
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@558044 13f79535-47bb-0310-9956-ffa450edef68
2007-07-20 16:47:40 +00:00
83a6eff431
move decision about being a slave from the Broker to the ConnectionContext - so can be done on a Connection basis if required
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@557748 13f79535-47bb-0310-9956-ffa450edef68
2007-07-19 19:24:31 +00:00
993f78caac
persist in-progress XA transactions - in order to speed up recovery
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@557391 13f79535-47bb-0310-9956-ffa450edef68
2007-07-18 20:34:19 +00:00
2438ada6ad
Split out Transaction class from AMQTrandactionStore -
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@557389 13f79535-47bb-0310-9956-ffa450edef68
2007-07-18 20:32:45 +00:00
3d1fca08fe
Added some java doc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@557386 13f79535-47bb-0310-9956-ffa450edef68
2007-07-18 20:31:09 +00:00
3cfa0b6e4d
Add a CommandMarshaller
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@557385 13f79535-47bb-0310-9956-ffa450edef68
2007-07-18 20:30:21 +00:00
71a3324b93
implement Comparable (well, badly)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@557384 13f79535-47bb-0310-9956-ffa450edef68
2007-07-18 20:29:13 +00:00
e34185fa01
fixed build...
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@554910 13f79535-47bb-0310-9956-ffa450edef68
2007-07-10 11:36:52 +00:00
677c22b4d5
Added support for custom destinations; for example to allow Camel endpoints to be used from within the JMS client
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@554315 13f79535-47bb-0310-9956-ffa450edef68
2007-07-08 05:39:00 +00:00
3d862f0dfb
allow the exclusive queue consumer flag to be defaulted on a connection factory / connection
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@553473 13f79535-47bb-0310-9956-ffa450edef68
2007-07-05 12:21:37 +00:00
94f3e17d7b
pretty print the local transport uri
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@553095 13f79535-47bb-0310-9956-ffa450edef68
2007-07-04 06:34:28 +00:00
4757541f96
set async=false for network connectors
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@553094 13f79535-47bb-0310-9956-ffa450edef68
2007-07-04 06:33:48 +00:00
241971a133
fix deadlock
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@553076 13f79535-47bb-0310-9956-ffa450edef68
2007-07-04 04:44:00 +00:00
0b95f87db0
ensure we don't use a batchEntry for an element that's deleted
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552845 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 14:06:38 +00:00
25a252f348
Added duplicate detection to the TransactionBroker - so can cope with rollbacks etc.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552738 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:31:10 +00:00
c7469c433c
Added flag to transport to denote if its fault tolerant
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552736 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:29:11 +00:00
f1240b2e72
Tests for internals
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552734 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:24:26 +00:00
82ce164d7a
Do this test properly
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552733 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:23:15 +00:00
4b7e5c914b
Audit test case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552732 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:21:28 +00:00
791d78bc64
Added another Constructor for convience that just takes the maximum number of cached items as a parameter
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552726 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:21:00 +00:00
cbaa58b508
Added duplicate detection on the client
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552713 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:19:33 +00:00
5f30e418cb
A helper class to assist checking for duplicates within the Connection
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@552710 13f79535-47bb-0310-9956-ffa450edef68
2007-07-03 08:17:10 +00:00
dd1d660149
Added dup detection capability
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@551902 13f79535-47bb-0310-9956-ffa450edef68
2007-06-29 14:07:46 +00:00
56be6b93d3
make sure we properly close down the advisory consumer; great catch by Manuel!
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@551857 13f79535-47bb-0310-9956-ffa450edef68
2007-06-29 11:34:20 +00:00
ec6e6a55a7
Display the establised Neteowork Connector Bridges via JMX - https://issues.apache.org/activemq/browse/AMQ-1299
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@551443 13f79535-47bb-0310-9956-ffa450edef68
2007-06-28 04:34:57 +00:00
b56197408a
Test using the AMQ Store
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@551437 13f79535-47bb-0310-9956-ffa450edef68
2007-06-28 03:43:05 +00:00
a3e382199c
ensure member variables are always synchronized
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@551271 13f79535-47bb-0310-9956-ffa450edef68
2007-06-27 18:53:30 +00:00
8a0157a506
added better synchronization
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550797 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 13:06:32 +00:00
8a5387f6ad
avoid concurrent modification exception on linux
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550796 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 13:04:40 +00:00
f6e1ac7f97
added NPE check
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550793 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 12:56:08 +00:00
8068c5e155
debug showing wrong parameter
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550699 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 05:38:14 +00:00
98cd515fff
fix for shutdown command
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550698 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 05:36:43 +00:00
bc281a209e
check input stream is not null on loading properties
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550695 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 05:13:54 +00:00
2bed73b2f1
My bad if not true (I don't see how it could be done) - but why is BrokerService serializable ? - now removed
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550694 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 05:11:51 +00:00
b484eeb595
member fields are now marked transient (as can't be serialized)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550692 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 05:05:31 +00:00
8f85fdc36c
change scope of variables from protected to private
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550690 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 05:03:37 +00:00
0e0b6b731c
tidied up imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550688 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 05:00:56 +00:00
1623820bf1
removed unused field
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550687 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 04:58:30 +00:00
0b769eee01
when seeting watcgTopicAdvisories on the connection - use the getter Method on the ConnectionFactory to retrieve the value
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550686 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 04:57:31 +00:00
f95552b621
removed useSyncSend - as never used (replaced by useAsyncSend)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550684 13f79535-47bb-0310-9956-ffa450edef68
2007-06-26 04:53:36 +00:00
d36c0d4de7
Applying patch from http://issues.apache.org/activemq/browse/AMQ-1293
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550449 13f79535-47bb-0310-9956-ffa450edef68
2007-06-25 10:45:55 +00:00
626cdf527a
applied patch from: http://www.nabble.com/forum/ViewPost.jtp?post=11263125&framed=y&skin=2354
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550393 13f79535-47bb-0310-9956-ffa450edef68
2007-06-25 07:02:36 +00:00
149fffda77
applied patch for issue: http://www.nabble.com/Performance-problem-in-ActiveMQ4.2-SNAPSHOT-tf3973867s2354.html#a11280202
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@550389 13f79535-47bb-0310-9956-ffa450edef68
2007-06-25 06:57:35 +00:00
2681bb89ee
ensure state is recovered if data is corrupted and has to be regenerated from transaction logs
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@549887 13f79535-47bb-0310-9956-ffa450edef68
2007-06-22 17:22:19 +00:00
0112df5605
added equals() hashCode() methods
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@549883 13f79535-47bb-0310-9956-ffa450edef68
2007-06-22 17:12:26 +00:00
2b84b2622f
applied patch for AMQ-1279
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@549834 13f79535-47bb-0310-9956-ffa450edef68
2007-06-22 15:01:23 +00:00
7993aae794
Add default constructor
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@549805 13f79535-47bb-0310-9956-ffa450edef68
2007-06-22 12:47:12 +00:00
9c2f043a65
Exclude duplex test - for now
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@549473 13f79535-47bb-0310-9956-ffa450edef68
2007-06-21 13:29:28 +00:00
fae5c5fd29
Fix for https://issues.apache.org/activemq/browse/AMQ-1071
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@548260 13f79535-47bb-0310-9956-ffa450edef68
2007-06-18 08:47:21 +00:00
4e0ee66db1
https://issues.apache.org/activemq/browse/AMQ-1284
...
change the openwire command annotation to correctly use code.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@548039 13f79535-47bb-0310-9956-ffa450edef68
2007-06-17 14:04:32 +00:00
ebcf2202fe
check we don't keep hold of a batch entry after its been deleted
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@547906 13f79535-47bb-0310-9956-ffa450edef68
2007-06-16 11:27:48 +00:00
4d1a176784
synchronized activate () and add() methods
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@547601 13f79535-47bb-0310-9956-ffa450edef68
2007-06-15 10:24:23 +00:00
fa5e0a0e15
applied patch for AMQ-1204
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@547586 13f79535-47bb-0310-9956-ffa450edef68
2007-06-15 08:55:43 +00:00
a0ba87b100
applied patch for AMQ-1204
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@547585 13f79535-47bb-0310-9956-ffa450edef68
2007-06-15 08:54:42 +00:00
78761dde4e
added xsddoc report
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@547570 13f79535-47bb-0310-9956-ffa450edef68
2007-06-15 07:41:54 +00:00
67310ad7dd
added more tests for using a remote schema using the nice new URLs
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@547211 13f79535-47bb-0310-9956-ffa450edef68
2007-06-14 10:49:36 +00:00
8a4fcd1934
Updated the spring xml to use the 5.0 AMQ xsd
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@547070 13f79535-47bb-0310-9956-ffa450edef68
2007-06-14 00:45:57 +00:00
28e6453bad
applied fix for AMQ-1232 and AMQ-1275
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546847 13f79535-47bb-0310-9956-ffa450edef68
2007-06-13 12:47:29 +00:00
4474eb8a1b
Added fix for http://issues.apache.org/activemq/browse/AMQ-1014 and http://issues.apache.org/activemq/browse/AMQ-1002
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546755 13f79535-47bb-0310-9956-ffa450edef68
2007-06-13 06:48:20 +00:00
acc3ca79f8
removed System.out.println statements
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546559 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 16:23:02 +00:00
b19f17c96b
removed tests cases using System.err to use log.error (or sometimes log.info) instead to tidy up the maven build
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546554 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 16:19:49 +00:00
7230da33c6
fixed typeo; bad james!
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546540 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 15:47:35 +00:00
aa1aa58caa
removed a load of System.out statements from unit tests; using commons-logging instead so the maven build is much cleaner
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546537 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 15:41:17 +00:00
5cb9419373
applied patch for AMQ-1229 with thanks!
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546485 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 13:53:37 +00:00
45f6a87244
removed some logging
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546483 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 13:49:52 +00:00
a6cb80ceb0
applied patch for AMQ-1146
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546482 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 13:42:52 +00:00
0eae2880cc
added test case and fix for AMQ-1142
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546476 13f79535-47bb-0310-9956-ffa450edef68
2007-06-12 13:24:33 +00:00
8ec100f564
Added a cluster field to each message so that each message can be persisted to a unique set of brokers working together as a master slave cluster.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546196 13f79535-47bb-0310-9956-ffa450edef68
2007-06-11 16:53:38 +00:00
b852dc87fc
applied patch for AMQ-1263 to create a new connection each time in case the connection goes stale
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@546120 13f79535-47bb-0310-9956-ffa450edef68
2007-06-11 12:21:11 +00:00
8f8ff58f8c
Updated the pom version from 4.2-SNAPSHOT to 5.0-SNAPSHOT
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@545505 13f79535-47bb-0310-9956-ffa450edef68
2007-06-08 13:55:40 +00:00
800cab1b3e
use the non-incubator xsd
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@545450 13f79535-47bb-0310-9956-ffa450edef68
2007-06-08 08:01:09 +00:00
21211dd6a1
Fix for the DefaultStoreXARecoveryBrokerTest test failure.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@545289 13f79535-47bb-0310-9956-ffa450edef68
2007-06-07 20:00:37 +00:00
70706ef20a
See http://issues.apache.org/activemq/browse/AMQ-1269
...
disabling failing test case combination.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@545233 13f79535-47bb-0310-9956-ffa450edef68
2007-06-07 16:29:18 +00:00
421b911da2
JmsTempDestinationTest was intermitently failing due to a timing issue.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@545232 13f79535-47bb-0310-9956-ffa450edef68
2007-06-07 16:19:09 +00:00
3965f2c34d
disabling failing test: https://issues.apache.org/activemq/browse/AMQ-1268
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@545228 13f79535-47bb-0310-9956-ffa450edef68
2007-06-07 16:15:29 +00:00
12dba4d65c
Fix for XARecoveryBrokerTest
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@545202 13f79535-47bb-0310-9956-ffa450edef68
2007-06-07 14:43:26 +00:00
f27715bcd9
Fix wrong commit on the pom.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@542429 13f79535-47bb-0310-9956-ffa450edef68
2007-05-29 06:42:48 +00:00
8786dbf593
Added spring test case that tests the locally generated xsd
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@542428 13f79535-47bb-0310-9956-ffa450edef68
2007-05-29 06:41:43 +00:00
a92fb28d75
tidied up javadoc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@541261 13f79535-47bb-0310-9956-ffa450edef68
2007-05-24 10:41:12 +00:00
72cee90f7a
fixed typeo
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@541260 13f79535-47bb-0310-9956-ffa450edef68
2007-05-24 10:31:16 +00:00
9d53c53dc8
improvement for AMQ-1253 so that the ConnectionFactory can be configured with the warning timeout (or have the warning disabled all together)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@541259 13f79535-47bb-0310-9956-ffa450edef68
2007-05-24 10:28:32 +00:00
78cf4b1ac1
added fix for AMQ-1253 to log a warning if users forget to start the connection within a small timeout period (500ms by default)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@541256 13f79535-47bb-0310-9956-ffa450edef68
2007-05-24 10:18:53 +00:00
e2b561e12b
fixed javadoc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@541232 13f79535-47bb-0310-9956-ffa450edef68
2007-05-24 09:10:56 +00:00
9b9766d034
added test case to try reproduce AMQ-1152 (but unfortunately couldn't)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@540916 13f79535-47bb-0310-9956-ffa450edef68
2007-05-23 10:18:20 +00:00
0d289b7c0c
fixed javadoc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@540881 13f79535-47bb-0310-9956-ffa450edef68
2007-05-23 08:29:44 +00:00
6641ef3ae7
Added support for microsofts JDBC driver
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@536601 13f79535-47bb-0310-9956-ffa450edef68
2007-05-09 17:50:26 +00:00
75c568012b
Amended patch for AMQ-1235 to not depend on Java 6
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@534046 13f79535-47bb-0310-9956-ffa450edef68
2007-05-01 12:51:47 +00:00
9f7fff7365
applied patch in https://issues.apache.org/activemq/browse/AMQ-1235
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@533740 13f79535-47bb-0310-9956-ffa450edef68
2007-04-30 13:15:39 +00:00
afba1a811d
Updated the javadoc generation to make a nicer report with groupings
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@533655 13f79535-47bb-0310-9956-ffa450edef68
2007-04-30 10:03:47 +00:00
2b0bd44cbb
Updated javadoc groups
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@532332 13f79535-47bb-0310-9956-ffa450edef68
2007-04-25 12:00:46 +00:00
3baaab2185
create default ProducerState for dummy ProducerBrokerExchange to prevent npe when sending to dead letter queues
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@530131 13f79535-47bb-0310-9956-ffa450edef68
2007-04-18 19:04:02 +00:00
d301cea84c
Make the test more forgiving of thread schedualing variations
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@524266 13f79535-47bb-0310-9956-ffa450edef68
2007-03-30 20:42:49 +00:00
9e8689ed28
Made the oracle driver use Blobs to fix AMQ-1216
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@524036 13f79535-47bb-0310-9956-ffa450edef68
2007-03-30 10:44:15 +00:00
5a521b468a
applied the patch from Aleksi Kallio for the DefaultBlobUploadStrategy and DefaultBlobUploadStrategyTest with thanks! For AMQ-1075
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@523332 13f79535-47bb-0310-9956-ffa450edef68
2007-03-28 14:03:22 +00:00
2632922be8
updated javadoc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@523283 13f79535-47bb-0310-9956-ffa450edef68
2007-03-28 11:30:14 +00:00
9dccfa4a8a
fixed the assembly so that the activemq broker script works again. Now moved from a Jetty snapshot to a release (6.1.2rc2) and also made BrokerService.setDataDirectory(String) take a string to avoid strange Spring errors we were getting
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@523279 13f79535-47bb-0310-9956-ffa450edef68
2007-03-28 11:15:22 +00:00
9bb3b0cbf6
fixed typeo
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@523266 13f79535-47bb-0310-9956-ffa450edef68
2007-03-28 10:35:51 +00:00
2ef81512d6
re-added name on the network connector
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@523259 13f79535-47bb-0310-9956-ffa450edef68
2007-03-28 10:17:44 +00:00
2a3f9e38ea
avoided double check locking bugs
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520937 13f79535-47bb-0310-9956-ffa450edef68
2007-03-21 16:19:26 +00:00
a2aed3d732
If localhost broker not started and other named broker exists - use that from vm:// transport instead of creating a new broker
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520870 13f79535-47bb-0310-9956-ffa450edef68
2007-03-21 12:54:10 +00:00
c328c72472
decrease message count for now
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520868 13f79535-47bb-0310-9956-ffa450edef68
2007-03-21 12:52:51 +00:00
2e06692aaf
tidier println() comment
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520866 13f79535-47bb-0310-9956-ffa450edef68
2007-03-21 12:52:11 +00:00
332aae366c
fixes for LargeStreamletTest
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520865 13f79535-47bb-0310-9956-ffa450edef68
2007-03-21 12:51:09 +00:00
47510d8eee
added soft bunny log message - so we don't scare folks when we delete all their messages on startup
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520819 13f79535-47bb-0310-9956-ffa450edef68
2007-03-21 09:37:39 +00:00
54114ccf77
fix for broker name not being registered with the network connector
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520814 13f79535-47bb-0310-9956-ffa450edef68
2007-03-21 09:18:56 +00:00
a59cd030f5
Implemented the per producer flow control on the Topic case too.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@519233 13f79535-47bb-0310-9956-ffa450edef68
2007-03-17 04:04:43 +00:00
a0e92d713b
removed the caching of the marshalled form of a message.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518745 13f79535-47bb-0310-9956-ffa450edef68
2007-03-15 20:15:04 +00:00
f7a30b80fc
Added test case that makes use of producer window flow control. So now even async sends can be flow controled so that an individual publisher can be stopped without stopping the entire connection.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518638 13f79535-47bb-0310-9956-ffa450edef68
2007-03-15 14:25:40 +00:00
e4bc8e14f6
added snippet macro...
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518636 13f79535-47bb-0310-9956-ffa450edef68
2007-03-15 14:17:48 +00:00
c729994739
rolled back the creation of the file: scheme and made the xbean: scheme handle files or URLs as well as classpath resources
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518632 13f79535-47bb-0310-9956-ffa450edef68
2007-03-15 14:10:24 +00:00
a640190fc4
added support for using a properties file to configure the broker to avoid the dependency on Spring and xbean; for AMQ-1206
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518590 13f79535-47bb-0310-9956-ffa450edef68
2007-03-15 11:39:04 +00:00
489f5aa204
- Propagate the AlwaysSyncSend setting from the ConnectionFactory to the Connection
...
- Got rid of the UseSyncSend property since AlwaysSyncSend was already there and did the same thing.
- Updated VMPendingMessageCursor so that it updates the reference counters of the message so that the usage managers are properly updated since the messages are being kept in memory.
- Updated the region Queue so that it decrements the usage in the case of a transaction.
- Enabled the ProducerFlowControlTest since it is now working.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518437 13f79535-47bb-0310-9956-ffa450edef68
2007-03-15 01:45:49 +00:00
b72c28b8a6
added JDBC driver for Sybase for AMQ-1204
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518296 13f79535-47bb-0310-9956-ffa450edef68
2007-03-14 19:58:31 +00:00
7162f01b75
default the usageManager to 64Mb rather than the measily 20m :)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@518260 13f79535-47bb-0310-9956-ffa450edef68
2007-03-14 18:37:31 +00:00
fbd22b637c
test for converting Properties to and from a String
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517764 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 16:39:46 +00:00
ae73f860b9
working towards a solution for http://issues.apache.org/activemq/browse/AMQ-920
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517753 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 16:19:58 +00:00
1d9737d577
updated javadoc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517748 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 16:08:10 +00:00
4741136695
add method to retrieve the URI used by the local VMTransport
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517741 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 15:53:24 +00:00
a51a7d53e2
added a helper method to access the current singleton broker
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517687 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 13:24:23 +00:00
ea42012ef1
added a file: based handler for the broker factory
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517671 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 12:47:19 +00:00
0ae6a1d6aa
added helper method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517659 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 12:08:25 +00:00
93d1087726
flush messages into journal on stop
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517567 13f79535-47bb-0310-9956-ffa450edef68
2007-03-13 06:56:08 +00:00
0527ebacc9
increment reference count on send
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517264 13f79535-47bb-0310-9956-ffa450edef68
2007-03-12 15:49:58 +00:00
7de0e81995
Porting over tests in the 4.1 branch and updated the UsageManager so that if a Limit is set, then
...
it is used instead of being % based off the parent.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@517222 13f79535-47bb-0310-9956-ffa450edef68
2007-03-12 14:01:01 +00:00
c0af1f5116
resolved class cast exception
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516756 13f79535-47bb-0310-9956-ffa450edef68
2007-03-10 17:38:46 +00:00
e8b12e4eaf
initialize brokerInfo
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516664 13f79535-47bb-0310-9956-ffa450edef68
2007-03-10 08:31:49 +00:00
fb3b6dba57
Enhanced the ActiveMQConnection to use the CommandVisitor instead of using a big if swtich
...
when handling commands from the broker. This should be slightly more efficient.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516492 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 18:23:44 +00:00
4207bd9cc0
Adding the bits need to do producer flow control with a window to the broker. Just implemented on the Queue case for now.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516475 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 17:29:30 +00:00
9a79d3411d
set duplex property
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516450 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 16:34:32 +00:00
4569d7d28d
Refactor so that the ProducerBrokerExchange is passed all the way down to the Topic and Queue implementations.
...
This is laying the ground work to implement window based producer flow control.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516444 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 15:59:14 +00:00
82201d28dd
Use the broker name in the directory used for the AMQStore and temp-store area
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516439 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 15:47:05 +00:00
dda3e2a429
added isStoreValid() method - used by AMQStore to determine if references need to be rebuilt
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516408 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 13:30:33 +00:00
cb3becf3c4
avoid NPE I was getting in the web console
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516401 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 12:48:36 +00:00
ba54ee86b2
added toString() method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516315 13f79535-47bb-0310-9956-ffa450edef68
2007-03-09 06:38:06 +00:00
b5a42599b1
use async=false for now
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516169 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 20:35:26 +00:00
c9bb1c97b2
Adding the client side bits needed to implement producer flow control using a window. Currently disabled since
...
the server side bits still need implementing.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516139 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 18:44:03 +00:00
67fd739b3a
Delete duplicate and redundant tests
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516113 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 17:30:46 +00:00
57ea011bee
ensure connection state (e.g. consumers) are delivered before testing message consumption
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516104 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 17:16:18 +00:00
2a6a441fb0
ensure connections are closed (so all messages are fludshed to the broker) before testing message delivery
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516067 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 15:14:45 +00:00
1d846a9e61
ensure connections are closed (so all messages are fludshed to the broker) before testing message delivery
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516063 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 14:53:40 +00:00
885c379914
Set the eol-style to native
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516048 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 14:20:29 +00:00
e935c5ad3b
added some extra properties to the MessagePull command for when we implement AMQ-1196
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516040 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 13:38:40 +00:00
eeafa1cfef
use request() instead of send()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516039 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 13:28:59 +00:00
e39a679d2f
fix broken test case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516038 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 13:28:58 +00:00
d7a14830c7
use request() instead of send()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516034 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 13:19:03 +00:00
544ffe9dce
re-enabled some tests and tinkered to make a frew work better
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516031 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 13:11:12 +00:00
222dd260e6
fixed javadoc
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516030 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 13:09:25 +00:00
12fa4de5c6
ensure connections are closed (so all messages are fludshed to the broker) before testing message delivery
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516012 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 11:16:12 +00:00
c97b97ed88
close connection before restarting the broker
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516008 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 10:59:29 +00:00
8ad375ff60
on close() don't storeState in synchronized block - as it can lead to a deadlock
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@516007 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 10:58:41 +00:00
da13d596a5
use async dispatch for vm:// transport by default
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515999 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 10:22:22 +00:00
a08a4a84c7
fix for QueueSubscriptionTest and SimpleDispatchPolicyTest
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515996 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 10:13:29 +00:00
dccd381c8f
fix for AMQ-1193
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515963 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 08:23:06 +00:00
825447a615
close connection required in some tests before the broker is re-started
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515940 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 06:29:04 +00:00
1a3f54c93f
Expose the wire format protocol to the ActiveMQConnection and TransportConnection objects
...
so that they know when then can use more advanced protocol options. This will be needed
to implement producer flow control acking.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515863 13f79535-47bb-0310-9956-ffa450edef68
2007-03-08 00:22:18 +00:00
10185cadd7
fix to avoid NPE
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515746 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 20:53:24 +00:00
2a3fddbdea
with AMQPersistenceAdapter being the default now- these tests are redundant
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515712 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 19:41:36 +00:00
618396d459
rolled back change for AMQ-944 which breaks multicast group names
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515689 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 18:37:40 +00:00
2ca08ce701
allow thread stack size to be configurable
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515682 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 18:27:25 +00:00
f8d86bce28
fixed bad failing test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515657 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 17:37:13 +00:00
ec14f6569d
Added a new windowSize field to the ProducerInfo command and added a new ProducerAck command. These will be needed to implement better producer flow control
...
where threads do not block on the broker side.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515654 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 17:23:07 +00:00
b3bbb9c2ea
check messageId when removing ConsumerMessageRef (pesky redo logs can add/delete things - breaking the assumption we always get a nice ordered behaviour for durable subs)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515630 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 16:15:08 +00:00
0d9b413256
remove unused imports
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515629 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 16:13:06 +00:00
c12d7bfa22
remove data store at end of the junit run
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515627 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 16:12:35 +00:00
f7db42a835
Fix for https://issues.apache.org/activemq/browse/AMQ-1189 , use 2 fields instead of 1 for the 2 usages of the consumer field to avoid CCE when using vm messaging.
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515625 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 16:11:50 +00:00
300a5b23cb
added toString()
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515609 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 15:33:50 +00:00
95b34d5f2b
fix for AMQ-1191 and AMQ-1109
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515606 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 15:29:01 +00:00
e3870495dd
- http://issues.apache.org/activemq/browse/AMQ-734
...
- the failover option is no longer supported to remove it from the interfeace.
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515602 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 15:15:54 +00:00
63b82516a4
applied patch for AMQ-944
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515556 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 13:04:19 +00:00
d57343cdb5
minor patch to avoid ClassCastException for AMQ-1189
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515524 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 10:44:14 +00:00
d00ce72595
not a problem to try and create a destination more than once
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515466 13f79535-47bb-0310-9956-ffa450edef68
2007-03-07 06:01:00 +00:00
05de2b1f47
Merged rev 515282 from 4.1 branch which add enhanced stomp tracing support
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515284 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 20:24:12 +00:00
1807dbbba3
minor fix to avoid exception in some test cases
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515193 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 16:31:46 +00:00
800fba7f6c
fix typo in optimisation that was breaking the virtual topic tests
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515175 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 16:28:10 +00:00
8011f907ef
Fix for AMQ-1188 to handle invalid URIs for host names on Linux
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515084 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 11:47:32 +00:00
d262dfd4a9
use a more friendly XBean name
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515064 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 10:49:41 +00:00
0b1a064092
enable setting of the ReferenceStoreAdapter
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515060 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 10:36:53 +00:00
985b4ce0df
Make AMQPersistenceAdaptor the default persistence engine for ActiveMQ 5.0
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515059 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 10:29:03 +00:00
759fd2829c
Deleted store implementations rapid and quick, as they are replaced by the AMQStore implementation
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515054 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 10:25:48 +00:00
aee4378a8a
make sure we delete the persistence store before starting
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@515019 13f79535-47bb-0310-9956-ffa450edef68
2007-03-06 08:22:54 +00:00
8be526c5ec
added toString() method
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514772 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 18:24:33 +00:00
bd7d59c38f
ported fix to trunk :
...
http://issues.apache.org/activemq/browse/AMQ-1176
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514754 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 18:04:44 +00:00
b743552137
ported fix to trunk :
...
http://issues.apache.org/activemq/browse/AMQ-1179
http://issues.apache.org/activemq/browse/AMQ-1180
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514734 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 17:03:36 +00:00
49ea0eddf6
ported fix to trunk :
...
http://issues.apache.org/activemq/browse/AMQ-1181
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514720 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 16:26:08 +00:00
e5b45f6b4b
ported fix to trunk :
...
http://issues.apache.org/activemq/browse/AMQ-1177
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514717 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 16:00:25 +00:00
46d98e1287
ported fix to trunk :
...
http://issues.apache.org/activemq/browse/AMQ-1173
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514701 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 15:47:59 +00:00
015cd8a7f9
ported fix to trunk :
...
http://issues.apache.org/activemq/browse/AMQ-1172
http://issues.apache.org/activemq/browse/AMQ-1174
http://issues.apache.org/activemq/browse/AMQ-1175
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514694 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 15:41:17 +00:00
ef1d3559f5
ported fixed in 4.1 to trunk. http://issues.apache.org/activemq/browse/AMQ-1178
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514668 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 13:55:57 +00:00
477fc859e6
performance optimization
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514593 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 07:49:50 +00:00
df15551a4b
messages from remote broker are now handled correctly again
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514592 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 07:48:06 +00:00
8432e0aafe
set the remote broker name on the remoteBroker
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514588 13f79535-47bb-0310-9956-ffa450edef68
2007-03-05 07:35:15 +00:00
2eaafc0c12
add wildcard info to the ConsumerBrokerExchange
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514365 13f79535-47bb-0310-9956-ffa450edef68
2007-03-04 06:47:54 +00:00
c3f4712ac9
Pass in broker name to the AMQPersistenceAdapter
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514364 13f79535-47bb-0310-9956-ffa450edef68
2007-03-04 06:46:52 +00:00
1191d5eeb2
make ProducerBrokerExchange mutable if the destination is composite
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514143 13f79535-47bb-0310-9956-ffa450edef68
2007-03-03 12:41:34 +00:00
1dc9d9d355
reset enableStatistics=true
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514140 13f79535-47bb-0310-9956-ffa450edef68
2007-03-03 12:32:25 +00:00
84eb9f8b69
performance tuning
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@514131 13f79535-47bb-0310-9956-ffa450edef68
2007-03-03 11:30:22 +00:00
31d327726a
Fixed Queue cursor test case for AMQ Store
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513921 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 20:00:11 +00:00
55fa95460c
transports copy messages after serializing them on to the wire. So move copy on send into
...
the vm:// transport only
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513920 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 19:59:21 +00:00
819b811a2e
test the AMQ Store cursors instead of Kaha
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513919 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 19:57:57 +00:00
4e21e15f7e
minor change to improve the test case
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513810 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 15:31:49 +00:00
32e84d6cd1
name the adapter correctly
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513769 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 14:02:14 +00:00
ccd81adc0f
set default recovery policy (can't be FixedCountSubscriptionRecoveryPolicy) - as that
...
can hog alot of memory if large messages are used
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513761 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 13:47:39 +00:00
deaeab06e2
fix for failing test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513759 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 13:44:16 +00:00
4089d75fb7
fix for failing test
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513758 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 13:43:58 +00:00
2241f2064f
increase default buffer size - to accomadate average message size - which is usually 1024
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513626 13f79535-47bb-0310-9956-ffa450edef68
2007-03-02 06:24:31 +00:00
4e2acd4a77
provide the option to always send messages synchronously - even if the messages are
...
non-persistent
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513543 13f79535-47bb-0310-9956-ffa450edef68
2007-03-01 22:43:47 +00:00
c0cd83870c
turbo charge performance ;)
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513494 13f79535-47bb-0310-9956-ffa450edef68
2007-03-01 21:13:40 +00:00
9fd9189a17
ensure deleteAllMessages gets passed to the persistence adapter whilst it still makes sense
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513467 13f79535-47bb-0310-9956-ffa450edef68
2007-03-01 19:43:12 +00:00
167f99a3a1
fix for jira issue: http://issues.apache.org/activemq/browse/AMQ-1121
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513455 13f79535-47bb-0310-9956-ffa450edef68
2007-03-01 19:24:17 +00:00
1ea6d27053
brief pacakage descriptions for javadocs
...
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513287 13f79535-47bb-0310-9956-ffa450edef68
2007-03-01 11:49:58 +00:00
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Robert Davies
James Strachan
Hiram R. Chirino
Guillaume Nodet
Jonas B. Lim
Adrian T. Co
Timothy A. Bish
Dain Sundstrom