Commit Graph

889 Commits

Author SHA1 Message Date
Hiram R. Chirino 65e40d03da The ItStillMarshallsTheSameTest looks like it's passing
Also did some work to get the http://jira.activemq.org/jira/browse/AMQ-522 to pass.



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@415356 13f79535-47bb-0310-9956-ffa450edef68
2006-06-19 16:03:50 +00:00
James Strachan 0f1dccee37 applied patch from Jason Sherman for AMQ-753 to expose the remote connection address in JMX - many thanks!
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@415306 13f79535-47bb-0310-9956-ffa450edef68
2006-06-19 12:32:59 +00:00
James Strachan 4c4f86a0d8 applied patch from Christopher G. Stach II for AMQ-747 to allow redelivery backoff to add a collision avoidence capability. Many thanks!
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@415300 13f79535-47bb-0310-9956-ffa450edef68
2006-06-19 11:55:44 +00:00
James Strachan 87dcdce239 added better javadoc
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@415293 13f79535-47bb-0310-9956-ffa450edef68
2006-06-19 11:12:20 +00:00
Hiram R. Chirino b3748b4fd8 http://issues.apache.org/activemq/browse/AMQ-759
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@415036 13f79535-47bb-0310-9956-ffa450edef68
2006-06-17 17:40:40 +00:00
James Strachan 319033f712 added patch to handle timeout exceptions gracefully
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414823 13f79535-47bb-0310-9956-ffa450edef68
2006-06-16 13:31:53 +00:00
James Strachan 60ba9da302 tidied up the example JNDI
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414808 13f79535-47bb-0310-9956-ffa450edef68
2006-06-16 12:01:39 +00:00
Hiram R. Chirino 944f9d60d7 http://issues.apache.org/activemq/browse/AMQ-754
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414652 13f79535-47bb-0310-9956-ffa450edef68
2006-06-15 18:42:52 +00:00
Hiram R. Chirino dee685f73c http://issues.apache.org/activemq/browse/AMQ-725
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414610 13f79535-47bb-0310-9956-ffa450edef68
2006-06-15 15:04:31 +00:00
Hiram R. Chirino 75270affd8 http://issues.apache.org/activemq/browse/AMQ-749
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414595 13f79535-47bb-0310-9956-ffa450edef68
2006-06-15 14:34:08 +00:00
Hiram R. Chirino c2a51115cd Applied http://issues.apache.org/activemq/browse/AMQ-608 thanks Kevin.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414443 13f79535-47bb-0310-9956-ffa450edef68
2006-06-15 03:04:15 +00:00
James Strachan 18aa6dd34a changed snippet macro
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@414154 13f79535-47bb-0310-9956-ffa450edef68
2006-06-14 08:56:50 +00:00
James Strachan 8ce74fa439 removed Java 5 dependency - naughty Nathan :)
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413838 13f79535-47bb-0310-9956-ffa450edef68
2006-06-13 08:49:13 +00:00
Nathan Christopher Mittler 021a2afd88 Implementing AMQ-748 - adding optional request-id header in connect message and corresponding response-id in the connected message. Updating StompTest to verify.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413770 13f79535-47bb-0310-9956-ffa450edef68
2006-06-13 00:03:00 +00:00
Nathan Christopher Mittler e9e8fd147d Fixing AMQ-664 - making broker assign JMSTimestamp to all incoming stomp messages. Updating unit tests to verify timestamp is received properly via JMS.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413769 13f79535-47bb-0310-9956-ffa450edef68
2006-06-12 23:50:16 +00:00
Hiram R. Chirino e264e6f9d1 http://issues.apache.org/activemq/browse/AMQ-682
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413733 13f79535-47bb-0310-9956-ffa450edef68
2006-06-12 19:42:33 +00:00
Hiram R. Chirino 7dafbb582f http://issues.apache.org/activemq/browse/AMQ-734
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413679 13f79535-47bb-0310-9956-ffa450edef68
2006-06-12 15:17:30 +00:00
Hiram R. Chirino c1a0cd6875 http://issues.apache.org/activemq/browse/AMQ-714
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413674 13f79535-47bb-0310-9956-ffa450edef68
2006-06-12 15:08:33 +00:00
James Strachan fcc9ae70b1 disabled another multicast test to get the m2 gbuild working
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413648 13f79535-47bb-0310-9956-ffa450edef68
2006-06-12 13:09:58 +00:00
James Strachan 2c8b312bda excluded failing test for AMQ-724
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@413014 13f79535-47bb-0310-9956-ffa450edef68
2006-06-09 11:03:01 +00:00
James Strachan cf1fc15ad5 fixed m2 build on java1.4
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412970 13f79535-47bb-0310-9956-ffa450edef68
2006-06-09 08:01:08 +00:00
Robert Davies 7a386be938 set default for optimize acknowledge to false
For performance - recommend use DUPS_OK acknowledge - at least its clear what your going to get -
and it performs better too

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412964 13f79535-47bb-0310-9956-ffa450edef68
2006-06-09 07:38:25 +00:00
James Strachan 37e3387bed applied patch for AMQ-731 from Christopher G. Stach II - many thanks!
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412950 13f79535-47bb-0310-9956-ffa450edef68
2006-06-09 06:41:37 +00:00
James Strachan 358bc87813 fixed compile error
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412811 13f79535-47bb-0310-9956-ffa450edef68
2006-06-08 17:43:16 +00:00
Hiram R. Chirino 55ac4358a4 Implemented:
http://issues.apache.org/activemq/browse/AMQ-742



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412802 13f79535-47bb-0310-9956-ffa450edef68
2006-06-08 17:02:30 +00:00
James Strachan bf310ef475 added a helper class to make writing new broker plugins easier (its just one POJO) together with adding a simple LoggingBrokerPlugin
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412801 13f79535-47bb-0310-9956-ffa450edef68
2006-06-08 17:01:53 +00:00
Hiram R. Chirino 1b4eb12723 The onSendPrepareMessageBody connection property was not being used. Removed it.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412783 13f79535-47bb-0310-9956-ffa450edef68
2006-06-08 15:50:29 +00:00
James Strachan c085df44f8 updated javadoc comments
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412781 13f79535-47bb-0310-9956-ffa450edef68
2006-06-08 15:37:36 +00:00
Hiram R. Chirino b4390246ca Fix for the following exception that could occur:
java.lang.UnsupportedOperationException
        at java.util.AbstractCollection.add(AbstractCollection.java:216)
        at java.util.AbstractCollection.addAll(AbstractCollection.java:318)
        at org.apache.activemq.store.journal.JournalPersistenceAdapter.getDestinations(JournalPersistenceAdapter.java:139)        at org.apache.activemq.broker.region.AbstractRegion.getInactiveDestinations(AbstractRegion.java:193)
        at org.apache.activemq.broker.region.TopicRegion.getInactiveDestinations(TopicRegion.java:254)
        at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:157)
        at org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:113)





git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412772 13f79535-47bb-0310-9956-ffa450edef68
2006-06-08 15:26:02 +00:00
James Strachan cf0570f75e updated the snippet tags
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412147 13f79535-47bb-0310-9956-ffa450edef68
2006-06-06 15:20:54 +00:00
James Strachan 5128a70420 added a better example XML configuration file we can use for snippet macro examples
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412141 13f79535-47bb-0310-9956-ffa450edef68
2006-06-06 15:12:25 +00:00
James Strachan a0397468fa minor refactor to reuse the lazy construction logic of the DataSource across the journaled and pure JDBC persistence adapter
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412110 13f79535-47bb-0310-9956-ffa450edef68
2006-06-06 13:06:54 +00:00
James Strachan d273cf9c8c added better exception message if a dataSource is not provided
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412076 13f79535-47bb-0310-9956-ffa450edef68
2006-06-06 10:55:22 +00:00
Hiram R. Chirino bc7aa98d45 trunk has moved onto 4.1 development.. if you want to work on 4.0.1 stuff, co the 4.0 branch!
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411906 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 20:16:30 +00:00
James Strachan 2b0279a9af added test case and fix for AMQ-724
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411881 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 18:19:01 +00:00
Hiram R. Chirino 7976ad976e Applied http://issues.apache.org/activemq/browse/AMQ-711
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411832 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 15:51:35 +00:00
James Strachan 72555fe834 applied patch from Danielius Jurna on AMQ-736 - many thanks!
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411788 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 13:48:45 +00:00
James Strachan 90fca6a3a4 disabled the UDP tests which fail on some platforms
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411770 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 12:37:12 +00:00
James Strachan 11fd909837 disabled the UDP tests which fail on some platforms
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411768 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 12:32:53 +00:00
James Strachan 7a369c4c0c disabled the UDP tests which fail on some platforms
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411766 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 12:28:44 +00:00
James Strachan 871476e195 disabled the UDP tests which fail on some platforms
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411743 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 11:14:27 +00:00
James Strachan 2db848f32d added test case for AMQ-736
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411733 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 10:33:45 +00:00
James Strachan f533b42f31 avoid NullPointerException
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411728 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 10:06:56 +00:00
James Strachan dc2919e8ca commented out a couple of tests which seem to fail in m2
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@411726 13f79535-47bb-0310-9956-ffa450edef68
2006-06-05 10:01:55 +00:00
Nathan Christopher Mittler a3b0e8ad7f AMQ-656: Applying patch_060518.zip. Moving scripts (under gram) to activemq-core.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409828 13f79535-47bb-0310-9956-ffa450edef68
2006-05-27 13:57:41 +00:00
Hiram R. Chirino 14fda24c87 Fix for: http://issues.apache.org/activemq/browse/AMQ-726
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409742 13f79535-47bb-0310-9956-ffa450edef68
2006-05-26 20:44:54 +00:00
Hiram R. Chirino aa049d2ce2 Kaha can now journal the changes it makes to the indexes so that they can be used to redo the changes on
failure.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409322 13f79535-47bb-0310-9956-ffa450edef68
2006-05-25 07:44:50 +00:00
Hiram R. Chirino cad2107dd7 - do layz intialization of the containers.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409303 13f79535-47bb-0310-9956-ffa450edef68
2006-05-25 04:58:35 +00:00
Hiram R. Chirino 129f879607 Changed the KahaStore so that it works with set of data and index managers.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409300 13f79535-47bb-0310-9956-ffa450edef68
2006-05-25 04:30:46 +00:00
Hiram R. Chirino aa026f1f6a - Added some of the intial infrastucture needed to be able to use that DataManager to do index file recovery.
- ObjectMarshaller now avoids doing byte[] allocations.
 - We now store the data item's size in the index file so that when we load data from the data file using a 
   DataItem object, the data payload can be read in 1 io operation, previously an extra io was need to find
   out the size of the payload.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409297 13f79535-47bb-0310-9956-ffa450edef68
2006-05-25 03:46:35 +00:00
James Strachan 9d3b3aef05 added better javadoc
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409136 13f79535-47bb-0310-9956-ffa450edef68
2006-05-24 11:06:37 +00:00
James Strachan d97fb0ce6e fixed javadoc
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@409129 13f79535-47bb-0310-9956-ffa450edef68
2006-05-24 10:44:46 +00:00
Hiram R. Chirino d671875ebf Applied patch at https://issues.apache.org/activemq/browse/AMQ-718
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@408776 13f79535-47bb-0310-9956-ffa450edef68
2006-05-22 22:43:35 +00:00
James Strachan deff26029f added another attempt to reproduce AMQ-715
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@408640 13f79535-47bb-0310-9956-ffa450edef68
2006-05-22 11:00:42 +00:00
James Strachan c172b50ccc failed attempt at replicating AMQ-715 which at least adds a few more test cases
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@408638 13f79535-47bb-0310-9956-ffa450edef68
2006-05-22 10:51:39 +00:00
Hiram R. Chirino 0fd46ce621 Test and Fix for http://issues.apache.org/activemq/browse/AMQ-715
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@407816 13f79535-47bb-0310-9956-ffa450edef68
2006-05-19 15:05:04 +00:00
Guillaume Nodet bca487a2bb Use a released plugin for javacc
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@407803 13f79535-47bb-0310-9956-ffa450edef68
2006-05-19 14:13:22 +00:00
Adrian T. Co e5bbcb532b - Made the consumers in some of the test cases retroactive to enable it to receive messages that was sent before its registration can be processed.
- Enabled SslTransportBrokerTest

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@406150 13f79535-47bb-0310-9956-ffa450edef68
2006-05-13 21:01:17 +00:00
Hiram R. Chirino a522d3abf7 Implementing a Rapid store which is a mix of the QuickJournal and the Kaha store.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@405807 13f79535-47bb-0310-9956-ffa450edef68
2006-05-12 17:52:51 +00:00
Hiram R. Chirino 7947655e5f Honnor the QoS requested by the client when replicating to the slave broker.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@405806 13f79535-47bb-0310-9956-ffa450edef68
2006-05-12 17:52:04 +00:00
James Strachan 3b973bce32 made it a little easier to extend the ActiveMQ JNDI provider
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@405737 13f79535-47bb-0310-9956-ffa450edef68
2006-05-10 12:38:06 +00:00
Hiram R. Chirino 9614aa9b4e Connection state tracking would cause a CCE if temp destinations were in use.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@405206 13f79535-47bb-0310-9956-ffa450edef68
2006-05-08 22:41:08 +00:00
James Strachan 89d6fd0a80 avoid NPE
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@400057 13f79535-47bb-0310-9956-ffa450edef68
2006-05-05 12:12:23 +00:00
James Strachan ac13202007 improved null handling after suggestions from Danielius Jurna
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399999 13f79535-47bb-0310-9956-ffa450edef68
2006-05-05 07:31:35 +00:00
Hiram R. Chirino 6e329f7d9e Avoid NPE in MasterBroker.processDispatch... a null message is sent to the client to signal end of queue browse.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399710 13f79535-47bb-0310-9956-ffa450edef68
2006-05-04 14:22:44 +00:00
James Strachan 2fd7ccbdf5 patched the pooled JMS provider to make it easier to configure the size and implementation of the underlying session pool
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399702 13f79535-47bb-0310-9956-ffa450edef68
2006-05-04 13:58:43 +00:00
Hiram R. Chirino c6e0984e1d Enable optimized ack by default again but disable the broker from sending the prefetch resize command to the client.. the client still has not implemented proper thread safe handling for that.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399530 13f79535-47bb-0310-9956-ffa450edef68
2006-05-04 03:45:59 +00:00
James Strachan eaad2f96f9 magical combination of excluded tests so that the build works on m2
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399312 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 14:10:07 +00:00
James Strachan 44493e4997 added helper methods to Destination POJOs so the MBeans are not required
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399298 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 13:38:26 +00:00
James Strachan 91732843ea added a tad of whitespace back :)
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399285 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 12:34:15 +00:00
James Strachan 2faad432f3 removed some system.out logging
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399260 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 11:22:07 +00:00
James Strachan 5e558f82d5 removed some system.out logging
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399259 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 11:21:19 +00:00
James Strachan 0afd5a8cf9 removed some system.out logging
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399256 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 11:12:12 +00:00
James Strachan 8c933fcc89 removed some system.out logging
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399250 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 10:56:52 +00:00
James Strachan 9f9fe90d85 removed some system.out logging
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399249 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 10:50:49 +00:00
James Strachan 3cbd06152b commented out more failing tests under m2
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@399237 13f79535-47bb-0310-9956-ffa450edef68
2006-05-03 10:13:33 +00:00
James Strachan c53bb05cd2 disabled logging
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398965 13f79535-47bb-0310-9956-ffa450edef68
2006-05-02 15:32:00 +00:00
James Strachan b06de590e0 ensure that the check of whether or not the ConnectionInfo is sent to the broker - and the clientID created - is thread safe to fix AMQ-696
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398928 13f79535-47bb-0310-9956-ffa450edef68
2006-05-02 12:29:28 +00:00
James Strachan 6b1682f949 added test case for AMQ-696
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398560 13f79535-47bb-0310-9956-ffa450edef68
2006-05-01 09:29:32 +00:00
Hiram R. Chirino 29b5ae57a2 Making the m2 release look like the m1 release
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398279 13f79535-47bb-0310-9956-ffa450edef68
2006-04-30 05:01:50 +00:00
Hiram R. Chirino b022a9d835 Set instance variables to null so that we don't OOM exceptions when using m2
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398076 13f79535-47bb-0310-9956-ffa450edef68
2006-04-29 03:22:23 +00:00
Hiram R. Chirino 794e8d7880 Ignore log messages from other software packages by default.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398018 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 21:26:22 +00:00
Hiram R. Chirino 653a7791f7 Disable optimizeAcknowledge for now. It is still not threadsafe. Tests fail on on 2 core windows box when this is enabled.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398016 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 21:25:43 +00:00
Hiram R. Chirino 807e18f9f9 - Gaurd access to dispatched list ( a sync was missing).
- Added better exception messages to know what happened when a slave subscription gets out of sync with the master.
- Implemented a simpler isFull()

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@398015 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 21:24:06 +00:00
Hiram R. Chirino d65ba8034b Gaurd access to the pending list better.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397985 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 19:13:54 +00:00
Hiram R. Chirino f5f1366e4b Include the prefetch size in the JMX stats of a subscription
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397982 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 19:02:01 +00:00
Hiram R. Chirino f1a0614066 Added a 'noRangeAcks' flag to the ConsumerInfo command
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397960 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 17:26:59 +00:00
Hiram R. Chirino 4009fda30c Organized imports
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397941 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 16:20:26 +00:00
Hiram R. Chirino f25e2ca23e Applyed Rodrigo S de Castro's latest unit test patch and fixed the redelivery problem. Redelivery was not being delayed when rollback was called from the message listener.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397915 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 15:11:39 +00:00
Hiram R. Chirino 03de4c2d8b Added testcase by Rodrigo S de Castro. Thanks Rodrigo!
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397908 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 14:07:27 +00:00
Hiram R. Chirino e2aad41e6a Since some OS/JVM combinations handle threads more efficiently than others, using a thread pool to run our async tasks may not
be the most optimal solution.  Modified the TaskRunnerFactory so that it uses a system property to choose between the 
PooledTaskRunner or the DedicatedTaskRunner which now keeps a dedicated thread per task.

The default is still set to use the PooledTaskRunner, but we may change this if performance benchmarks indicate that DedicatedTaskRunner should be the default.

Also make the thread names a little more uniform so that when you use a debugger you can easily tell what each thread is doing.




git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397774 13f79535-47bb-0310-9956-ffa450edef68
2006-04-28 05:54:54 +00:00
Hiram R. Chirino cb1d21f0a3 Fix for http://issues.apache.org/activemq/browse/AMQ-695
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397613 13f79535-47bb-0310-9956-ffa450edef68
2006-04-27 19:11:38 +00:00
Robert Davies a17b95182f close local transport if remote transport fails (and supports failover), and re-establish local transport on a successful re-connect
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397589 13f79535-47bb-0310-9956-ffa450edef68
2006-04-27 16:59:18 +00:00
Robert Davies 40b96b1b8f Fix for Queues getting full in the broker
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397420 13f79535-47bb-0310-9956-ffa450edef68
2006-04-27 05:47:28 +00:00
Hiram R. Chirino 93dc39b130 changed a bunch of System.out.println() to log.info()
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397249 13f79535-47bb-0310-9956-ffa450edef68
2006-04-26 17:25:42 +00:00
James Strachan d680ba1291 added some helper methods to make it easier to access management information without having to use explicit JMX APIs
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397198 13f79535-47bb-0310-9956-ffa450edef68
2006-04-26 13:54:11 +00:00
James Strachan 4e65119cff disabled test case that has a timing issue
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397193 13f79535-47bb-0310-9956-ffa450edef68
2006-04-26 13:22:48 +00:00
James Strachan 35f915f3b9 updated the javadoc to be more explicit about the limitations of the pool package
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@397168 13f79535-47bb-0310-9956-ffa450edef68
2006-04-26 10:49:02 +00:00
Hiram R. Chirino 535e16a3e4 It was possible to return a marshalled command before previously added pending commands. And have the commands run out of order. For examples, an unsubscribe could be executed before all it's ack were run. This fix forces commands to allways be run in enqueued order.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396957 13f79535-47bb-0310-9956-ffa450edef68
2006-04-25 19:22:29 +00:00
James Strachan 8ad6fd36a1 added a helper method to make it easier to work with the admin view together with fixed some NPEs I was getting when redeploying ActiveMQ when using mvn jetty6:run
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396892 13f79535-47bb-0310-9956-ffa450edef68
2006-04-25 14:06:52 +00:00
James Strachan 73f0e97531 added helper classes for comparing messages
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396891 13f79535-47bb-0310-9956-ffa450edef68
2006-04-25 14:05:03 +00:00
Hiram R. Chirino 53454ccb36 Don't open data files again if the store has been closed.. on windows tests were failing since the open data files could not be deleted.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396583 13f79535-47bb-0310-9956-ffa450edef68
2006-04-24 15:41:59 +00:00
Hiram R. Chirino 75c9b638be Close data files when the store is closed
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@396040 13f79535-47bb-0310-9956-ffa450edef68
2006-04-22 00:58:16 +00:00
Robert Davies 065c46f19d put back support for request/reply across networks
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395810 13f79535-47bb-0310-9956-ffa450edef68
2006-04-21 08:02:19 +00:00
Robert Davies a16b869fd8 more tuning - and ensure data files have more meaningful names
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395689 13f79535-47bb-0310-9956-ffa450edef68
2006-04-20 20:07:32 +00:00
Hiram R. Chirino 9cf5f45cf6 If we get an async exception, report it to all blocked sync requests.
https://issues.apache.org/activemq/browse/AMQ-691


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395641 13f79535-47bb-0310-9956-ffa450edef68
2006-04-20 16:58:58 +00:00
Hiram R. Chirino 2ee58ca235 Support "transport." properties when creating a tranport server
Support "socket." properties when creating a transport.


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395640 13f79535-47bb-0310-9956-ffa450edef68
2006-04-20 16:57:56 +00:00
Robert Davies fa8b889906 finese tuning
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395611 13f79535-47bb-0310-9956-ffa450edef68
2006-04-20 14:58:50 +00:00
Robert Davies 6575f2d22d tuning around kaha persistence
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395597 13f79535-47bb-0310-9956-ffa450edef68
2006-04-20 14:15:30 +00:00
Robert Davies 2c64bf99d9 fine tuning
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395256 13f79535-47bb-0310-9956-ffa450edef68
2006-04-19 14:46:25 +00:00
Robert Davies 5c7f4b626b messages not getting acked
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@395254 13f79535-47bb-0310-9956-ffa450edef68
2006-04-19 14:39:49 +00:00
Hiram R. Chirino b708fd32c3 Properly handle a rollback() when call from an onMessaqge()
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394851 13f79535-47bb-0310-9956-ffa450edef68
2006-04-18 05:50:40 +00:00
Hiram R. Chirino 535c30c3e8 handle sync send timeouts better.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394811 13f79535-47bb-0310-9956-ffa450edef68
2006-04-17 23:49:01 +00:00
Guillaume Nodet 1e6c45fb2e Fix dependencies scopes for m2 build...
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394797 13f79535-47bb-0310-9956-ffa450edef68
2006-04-17 22:39:14 +00:00
Hiram R. Chirino dcf7dea53f An async error could cause a deadlock when using the VM transport since all it's operations are sync. The error handling is now done in an async thread to avoid the deadlock.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394729 13f79535-47bb-0310-9956-ffa450edef68
2006-04-17 17:04:59 +00:00
Hiram R. Chirino 178f34bd9b Missing synchronization would cause acks to not be delivered to the broker. After enough acks were missed,
the consumer would stop receiving messages due to the broker thinking the consumers prefetch is full.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394710 13f79535-47bb-0310-9956-ffa450edef68
2006-04-17 15:36:04 +00:00
Hiram R. Chirino c46562ba7c If a topic consumer was hung up, it would eventually stop the producers since the broker memory limit would be reached.
The problem was if the consumer was killed, the broker memory would not get freed up and so the producer would remain blocked.
When a subscription is removed, the memory of the pending messages are now released.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394707 13f79535-47bb-0310-9956-ffa450edef68
2006-04-17 15:32:28 +00:00
Hiram R. Chirino 91720daee7 On consumer close, wait for it's async threads to finish before returning. Was getting errors when async acks were sent and the subscription was allready closed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394705 13f79535-47bb-0310-9956-ffa450edef68
2006-04-17 15:29:43 +00:00
Guillaume Nodet bfa4b9bb68 Fix m2 build: the distribution is nearly identical to the m1 dist.
Remaining problems: missing STATUS file, and activemq.rar is way too big

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394399 13f79535-47bb-0310-9956-ffa450edef68
2006-04-15 23:33:05 +00:00
Hiram R. Chirino 5c03c7df96 frame builder was not adding all the properties (they were not all String values).
Connect should also use the\0\n convention that the frame builder uses.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394269 13f79535-47bb-0310-9956-ffa450edef68
2006-04-15 08:26:30 +00:00
Hiram R. Chirino e73fa1201a Get bytes messages to work right with pub sub.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394242 13f79535-47bb-0310-9956-ffa450edef68
2006-04-15 02:05:04 +00:00
Hiram R. Chirino 5706bed79d ah.. onMesage was causing the bytes messages content to be nulled.. setting the readOnly properties manually.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394145 13f79535-47bb-0310-9956-ffa450edef68
2006-04-14 17:22:41 +00:00
Hiram R. Chirino 51d3c8260c message.onSend() was not being called causing the readOnly fields to not be properly initialized.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394142 13f79535-47bb-0310-9956-ffa450edef68
2006-04-14 17:12:59 +00:00
Robert Davies 6eaea6f336 For optimized acknowledge, eagerly get acknowledgements from consumers
when the dispatched list gets too big.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@394050 13f79535-47bb-0310-9956-ffa450edef68
2006-04-14 08:38:50 +00:00
Robert Davies 6d366dcc85 fine tuning, client control commands etc.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393913 13f79535-47bb-0310-9956-ffa450edef68
2006-04-13 20:16:24 +00:00
Robert Davies ef0734bccf fine tuning, client control commands etc.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393912 13f79535-47bb-0310-9956-ffa450edef68
2006-04-13 20:15:35 +00:00
Robert Davies 52ee976ec8 added support for clearing messages in-flight
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393495 13f79535-47bb-0310-9956-ffa450edef68
2006-04-12 16:18:36 +00:00
Robert Davies 00d054a6c2 more tuning
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393490 13f79535-47bb-0310-9956-ffa450edef68
2006-04-12 15:52:06 +00:00
Robert Davies 28647f1790 added changes from http://jira.activemq.org/jira//browse/AMQ-660
to allow destination conversation on outbound messages with replyTo destinations



git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393383 13f79535-47bb-0310-9956-ffa450edef68
2006-04-12 04:46:22 +00:00
Robert Davies d964145532 extra peformance tuning parameters
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393294 13f79535-47bb-0310-9956-ffa450edef68
2006-04-11 19:09:11 +00:00
Hiram R. Chirino 014c62bc56 Better DB2 support. Thanks goes to Klaus Terjung on activemq-users list for providing the needed info.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393265 13f79535-47bb-0310-9956-ffa450edef68
2006-04-11 17:29:26 +00:00
Hiram R. Chirino a2ae3a9f8a The JMSDurableTopicRedeliverTest was failing intermitently.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393106 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 22:29:40 +00:00
Hiram R. Chirino 700ba75d55 If multicast is not properly configured.. we run the chance of filling the logs with error messages on a vanila install.
We now gard against this by only reporting the error mesasge the first time we hit the error. We keep trying to do mutlicast advertising, but
suppress futher error messages.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393054 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 20:41:13 +00:00
Robert Davies daddd413a2 don't throw excpetion if directory doesn't exist when removing
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393051 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 20:39:00 +00:00
Hiram R. Chirino 3043e7ab31 test case for tempDest.delete() was failing. It could be that the advisory topics were never created for a temp topic so its delete operation would fail.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393048 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 20:29:23 +00:00
Robert Davies c852f0755b some tuning of default buffer sizes etc.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@393024 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 19:09:55 +00:00
Robert Davies c7be305873 fix for https://issues.apache.org/activemq/browse/AMQ-687
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392992 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 17:18:21 +00:00
Robert Davies a1e410f761 another memory leak fixed
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392929 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 12:19:24 +00:00
Robert Davies b792f11767 fixes for memory leaks
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392904 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 08:12:09 +00:00
Robert Davies fdd4b4e3e8 Added test case for multiple consumers
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392888 13f79535-47bb-0310-9956-ffa450edef68
2006-04-10 05:12:31 +00:00
Robert Davies 2373eb2d22 fix for http://issues.apache.org/activemq/browse/AMQ-683
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392624 13f79535-47bb-0310-9956-ffa450edef68
2006-04-08 22:48:33 +00:00
Robert Davies 973147afb0 Fix for http://issues.apache.org/activemq/browse/AMQ-677
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392623 13f79535-47bb-0310-9956-ffa450edef68
2006-04-08 22:47:09 +00:00
Robert Davies 9cd60d8c5d removed SPLATTT! comment
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392487 13f79535-47bb-0310-9956-ffa450edef68
2006-04-08 07:07:15 +00:00
Robert Davies 3c72961e09 handle concurrent close errors
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392441 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 22:31:53 +00:00
Robert Davies d8546c2567 remove Thread.dump on error condition
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392440 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 22:31:04 +00:00
Robert Davies 72923b8cbb fix for http://issues.apache.org/activemq/browse/AMQ-676
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392434 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 22:02:07 +00:00
Robert Davies 3c10ee0f52 updated comments
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392433 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 21:59:20 +00:00
James Strachan cc6fec68f4 added a hook to eagerly evict expired messages on non-durable topics first before we apply other eviction policies such as old messages etc
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392349 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 17:58:17 +00:00
Hiram R. Chirino 46d62dff70 enable keepDurableSubsActive by default. See:
http://issues.apache.org/activemq/browse/AMQ-669


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392323 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 15:38:38 +00:00
Hiram R. Chirino 84fd773f27 Updated the Transport interface so that you can pass in a ResponseCallback object that will be called when the response for a request arrives.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392288 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 13:31:59 +00:00
Hiram R. Chirino 064880b08a Was having some jmx dup id issues.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392283 13f79535-47bb-0310-9956-ffa450edef68
2006-04-07 13:20:16 +00:00
James Strachan 68779c0aa5 changed UDP port of test cases to see if this fixes the ci.gbuild.org build
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392083 13f79535-47bb-0310-9956-ffa450edef68
2006-04-06 21:24:58 +00:00
Hiram R. Chirino d724f9ed4d Group the connections using the connector name that they were created from.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392043 13f79535-47bb-0310-9956-ffa450edef68
2006-04-06 19:15:29 +00:00
James Strachan b76530740e allow folks to serialize the broker service if they really need to
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392035 13f79535-47bb-0310-9956-ffa450edef68
2006-04-06 18:56:36 +00:00
James Strachan 2f7ab76817 insure unique JMX names across multiple connectors and connections
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@392003 13f79535-47bb-0310-9956-ffa450edef68
2006-04-06 15:53:32 +00:00
James Strachan 5982b208d4 added initial config file for DB2 universal driver
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391998 13f79535-47bb-0310-9956-ffa450edef68
2006-04-06 14:58:53 +00:00
Hiram R. Chirino 23d80b3c71 List the unique id of the broker when it's started and stopped.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391821 13f79535-47bb-0310-9956-ffa450edef68
2006-04-05 21:26:03 +00:00
Hiram R. Chirino d65cc6311f do smarted chechkpointing based on usage.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391820 13f79535-47bb-0310-9956-ffa450edef68
2006-04-05 21:25:25 +00:00
Hiram R. Chirino b6673c4bf3 Fix for https://issues.apache.org/activemq/browse/AMQ-662
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391819 13f79535-47bb-0310-9956-ffa450edef68
2006-04-05 21:23:34 +00:00
Robert Davies 3b1a7d66de comment out KahaXARecoveryBrokerTest
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391607 13f79535-47bb-0310-9956-ffa450edef68
2006-04-05 12:58:48 +00:00
James Strachan 9d50686820 added underscore to look more like other rendezvous services
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391272 13f79535-47bb-0310-9956-ffa450edef68
2006-04-04 11:14:12 +00:00
James Strachan cda091cb5e allow any implementation of PersistenceAdapterFactory to be used
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391096 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 18:00:07 +00:00
James Strachan 609681a0cb allow any implementation of PersistenceAdapterFactory to be used
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391091 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 17:39:32 +00:00
Robert Davies 39ad4a84cb change some frequent info logging to debug
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391054 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 14:23:51 +00:00
Robert Davies 1ffd9f88a9 Add some basic testing of the Kaha persistence adaptor
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391053 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 14:15:17 +00:00
Robert Davies ff6a6e834e test transactions don't through any funnies
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391052 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 14:13:57 +00:00
Robert Davies 0e6a7e4897 extended so can be used by Transaction tests for Master Slave
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391051 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 14:13:29 +00:00
Robert Davies 0a7ade231a close the thing on a stop
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391050 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 14:12:48 +00:00
Robert Davies e9b1ff51ee resolve some timing issues
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@391049 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 14:12:11 +00:00
Robert Davies 05d271a719 prevent ObjectNames being unregistered from the MBeanServer if already removed in doStop()
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390998 13f79535-47bb-0310-9956-ffa450edef68
2006-04-03 10:43:55 +00:00
Robert Davies a748040d31 don't iterate through dispatchQueue if the broker is stopped
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390614 13f79535-47bb-0310-9956-ffa450edef68
2006-04-01 08:03:05 +00:00
Hiram R. Chirino ea1dad712a Implemented: http://issues.apache.org/activemq/browse/AMQ-673
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390470 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 18:12:24 +00:00
Hiram R. Chirino 8999aa10e0 Just use usage monitoring to cause the early checkpoints to happen.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390449 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 16:06:37 +00:00
Robert Davies 8f02ba6a53 fix for NPE
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390411 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 12:50:18 +00:00
James Strachan d68fe55933 added better exception message
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390379 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 09:31:57 +00:00
Robert Davies a38a90657b fixed some issues with measuring durable topic subscriber performance
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390376 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 09:07:15 +00:00
James Strachan f732943141 disabled rendezvous test by default as it fails on some OS'es
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390375 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 09:05:05 +00:00
Robert Davies 2af7d9836e sbe fix on collections toArray(Object[])
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390374 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 09:03:44 +00:00
Robert Davies e44aee930e added properties for userName/password
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390370 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 08:58:20 +00:00
Robert Davies 44ab524349 patch for https://issues.apache.org/activemq/browse/AMQ-672 - supplied by Mike Gerdes
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390369 13f79535-47bb-0310-9956-ffa450edef68
2006-03-31 08:54:04 +00:00
Hiram R. Chirino 161c24aa16 Changed the KeepAliveInfo packet so that it extends BaseCommand so that a reply can be requested. Should will allow for a broker or a client to get almost imediate feedback to see if the connection is down.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390200 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 18:06:06 +00:00
James Strachan d458445245 added test case for rendezvous
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390164 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 15:39:15 +00:00
James Strachan 1a917fe88f added test case for rendezvous
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390163 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 15:35:20 +00:00
James Strachan 217e0c8527 fixed typeo and made synchronized collection private
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390149 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 14:37:24 +00:00
James Strachan d9729e86d4 fixed old startup text - thx for the catch Geir
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390117 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 13:20:08 +00:00
James Strachan e830585455 interupt thread on exception
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390056 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 10:01:09 +00:00
James Strachan 2ed21cedd0 removed a couple of possible concurrent accesses of the message collection
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390041 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 09:15:47 +00:00
Frederick G. Oconer b8b2258fc7 Fix for maven 2 builds and organized the dependencies.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389950 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 01:12:00 +00:00
Hiram R. Chirino 18d616c8db - Since we now have per destination usage managers, I updated the MessageStore API so that each destination's store can be maded aware of the manager for that store.
Some stores like the journal hold messages around and use the usage manager to know when it should flush to disk.
- Moved alot of the message reference counting logic from the PrefetchSubscription up to it's subclasses since they all seem to do it just a slightly different way.
  I think it makes easier to see now how the usage manager is affected by operations.
- I fixed and verifed that the keepDurableSubsActive=true option actually works.  I think we should make this the default setting since it
  make recovery safer.  Once we have a better spooling implementation we can turn if off again.


git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389941 13f79535-47bb-0310-9956-ffa450edef68
2006-03-30 00:36:21 +00:00
Hiram R. Chirino f1e3420e1d better debug so we can see the sql statement being executed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389893 13f79535-47bb-0310-9956-ffa450edef68
2006-03-29 21:20:57 +00:00
Hiram R. Chirino 38d8b832ef Better content-length handling.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389845 13f79535-47bb-0310-9956-ffa450edef68
2006-03-29 17:52:01 +00:00
Hiram R. Chirino c80b084cdc Use the JMS methods to get the bytes in a BytesMessage since those decompress the payload if the content was compressed.
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389841 13f79535-47bb-0310-9956-ffa450edef68
2006-03-29 17:26:58 +00:00
Hiram R. Chirino 449981be9d Working on https://issues.apache.org/activemq/browse/AMQ-669
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389614 13f79535-47bb-0310-9956-ffa450edef68
2006-03-28 22:10:34 +00:00
James Strachan 8c20a11a43 tidied up the connection/producer/consumer/destination visualisation
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389554 13f79535-47bb-0310-9956-ffa450edef68
2006-03-28 17:48:15 +00:00
Hiram R. Chirino 0797d088d3 https://issues.apache.org/activemq/browse/AMQ-660
adding support for MaxDB

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389551 13f79535-47bb-0310-9956-ffa450edef68
2006-03-28 17:23:55 +00:00
James Strachan 24404740a1 moved the SSL transport into the main core module and switched to using our own TCP transport by default (as well as refactoring to make the [Server]SocketFactory objects pluggable
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389536 13f79535-47bb-0310-9956-ffa450edef68
2006-03-28 16:29:41 +00:00
James Strachan 2a076d0710 added some test cases (that are not yet working) for reliable UDP
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389533 13f79535-47bb-0310-9956-ffa450edef68
2006-03-28 16:19:23 +00:00
James Strachan d1a18f5787 added extra visualisation plugin; to render the broker, connections, sessions, consumers in a DOT graph
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389519 13f79535-47bb-0310-9956-ffa450edef68
2006-03-28 15:27:55 +00:00
Hiram R. Chirino 28316bb0bb Fix for http://issues.apache.org/activemq/browse/AMQ-659
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389258 13f79535-47bb-0310-9956-ffa450edef68
2006-03-27 20:29:56 +00:00
James Strachan 4ba19cad18 minor refactor to share code
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@389021 13f79535-47bb-0310-9956-ffa450edef68
2006-03-27 04:53:51 +00:00