Changelog Report

Timeframe: 30 days, Total Commits: 264 Total Number of Files Changed: 989

DateAuthorFile/Message
2004-08-19 15:52:27James Strachan

xdocs/index.xml v 1.2

Tidied up release process
2004-08-19 15:51:04James Strachan

README.txt v 1.8

maven.xml v 1.59

xdocs/index.xml v 1.1

Tidied up release process
2004-08-19 14:53:05James Strachan

maven.xml v 1.58

project.xml v 1.116

updated version ready for release
2004-08-19 14:51:12James Strachan

modules/container/src/java/org/codehaus/activemq/bean/BridgeBean.java v 1.1

modules/container/src/java/org/codehaus/activemq/bean/JmsHelper.java v 1.1

modules/container/src/test/org/codehaus/activemq/mdo/ServiceBean.java v 1.1

src/java/org/codehaus/activemq/gbean/ActiveMQConnector.java v 1.1

src/java/org/codehaus/activemq/gbean/ActiveMQContainer.java v 1.1

src/java/org/codehaus/activemq/gbean/package.html v 1.1

src/rar/META-INF/geronimo-ra.xml v 1.10

refactored the activemq.container package to be activemq.gbean to make it more clear its purpose and to avoid confusion (since we way end up building a lightweight JMS container at some point and we also have BrokerContainer as a class etc)
2004-08-19 14:11:16James Strachan

modules/base-project.xml v 1.4

fixed system test project
2004-08-19 13:00:41James Strachan

modules/systest/bdb/maven.xml v 1.3

modules/systest/bdb/project.xml v 1.6

fixed system test project
2004-08-19 12:39:57James Strachan

project.xml v 1.115

tidied javadoc
2004-08-19 12:36:54James Strachan

modules/systest/bdb/project.xml v 1.5

fixed systest build
2004-08-19 12:17:57James Strachan

src/sample-conf/default.xml v 1.3

tidied deployment descriptor
2004-08-19 11:59:57James Strachan

src/sample-conf/default.xml v 1.2

tidied example config file
2004-08-19 11:34:20James Strachan

src/java/org/codehaus/activemq/message/ActiveMQXid.java v 1.8

src/test/org/codehaus/activemq/message/ActiveMQObjectMessageTest.java v 1.2

fix to implement Comparable for ActiveXid so things work with the new JDBM
2004-08-19 11:33:34James Strachan

src/test/org/codehaus/activemq/message/ActiveMQXidTest.java v 1.2

fix to implement Comparable for ActiveXid so things work with the new JDBM
2004-08-19 11:16:37James Strachan

project.xml v 1.114

src/java/org/codehaus/activemq/store/jdbm/JdbmMessageStore.java v 1.3

src/java/org/codehaus/activemq/store/jdbm/JdbmPersistenceAdapter.java v 1.5

src/java/org/codehaus/activemq/store/jdbm/JdbmPreparedTransactionStore.java v 1.3

src/java/org/codehaus/activemq/store/jdbm/JdbmTopicMessageStore.java v 1.3

src/java/org/codehaus/activemq/util/DefaultComparator.java v 1.1

src/test/org/codehaus/activemq/store/howl/HowlQueueMessageStoreTest.java v 1.3

src/test/org/codehaus/activemq/store/jdbm/JdbmQueueMessageContainerTest.java v 1.2

src/test/org/codehaus/activemq/store/jdbm/JdbmQueueMessageStoreTest.java v 1.2

src/test/org/codehaus/activemq/store/jdbm/JdbmTopicMessageStoreTest.java v 1.2

src/test/org/codehaus/activemq/store/jdbm/OrderTest.java v 1.3

upgraded JDBM to use the latest 0.20 style code which includes transaction manager hooks and an optional cache
2004-08-19 11:15:58James Strachan

src/java/org/codehaus/activemq/service/MessageIdentity.java v 1.7

upgraded JDBM to use the latest 0.20 style code which includes transaction manager hooks and an optional cache
2004-08-19 09:08:56James Strachan

maven.xml v 1.57

src/java/org/codehaus/activemq/spring/Main.java v 1.2

src/sample-conf/bdb-example.xml v 1.1

src/sample-conf/default.xml v 1.1

src/sample-conf/howl-example.xml v 1.1

src/sample-conf/jdbc-example.xml v 1.1

src/sample-conf/jdbm-example.xml v 1.1

src/sample-conf/vm-example.xml v 1.1

src/test/log4j.properties v 1.3

src/test/org/codehaus/activemq/config/ConfigTest.java v 1.9

src/test/org/codehaus/activemq/config/howl-example.xml v 1.3

src/test/org/codehaus/activemq/config/jdbc-example.xml v 1.4

src/test/org/codehaus/activemq/config/jdbm-example.xml v 1.4

src/test/org/codehaus/activemq/config/vm-example.xml v 1.4

moved example config files out to a simpler directory to use. Also changed the 'server' goal to use a Spring XML config file if no URL is specified
2004-08-19 08:27:06James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.19

avoided unnecessary copy of collection
2004-08-19 08:14:07James Strachan

src/java/org/codehaus/activemq/service/impl/DispatchWorker.java v 1.9

avoid unnecessary toArray() as the implementation will never throw concurrent modificatino exception
2004-08-19 07:21:18James Strachan

src/test/org/codehaus/activemq/JmsTopicRequestReplyTest.java v 1.4

increased timer to try get test case to pass on the opteron box
2004-08-18 17:44:03James Strachan

project.xml v 1.113

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.11

src/java/org/codehaus/activemq/util/JMSExceptionHelper.java v 1.9

Updated my email address and applied a patch to allow ActiveCluster / ActiveSpace to work whether JDBM or BDB is on the classpath
2004-08-18 14:33:08James Strachan

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.50

src/java/org/codehaus/activemq/ActiveMQConnectionFactory.java v 1.29

src/java/org/codehaus/activemq/ActiveMQMessageAudit.java v 1.3

src/java/org/codehaus/activemq/ActiveMQMessageProducer.java v 1.18

src/java/org/codehaus/activemq/ActiveMQSession.java v 1.38

src/java/org/codehaus/activemq/message/ActiveMQMessage.java v 1.21

src/java/org/codehaus/activemq/store/PersistenceAdapter.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/JDBCPersistenceAdapter.java v 1.4

src/java/org/codehaus/activemq/transport/FactoryFinder.java v 1.3

src/java/org/codehaus/activemq/transport/IdGenerator.java v 1.11

src/java/org/codehaus/activemq/transport/TransportChannelProvider.java v 1.12

src/java/org/codehaus/activemq/transport/TransportServerChannelProvider.java v 1.13

src/java/org/codehaus/activemq/transport/ember/EmberTransportChannelFactory.java v 1.8

src/java/org/codehaus/activemq/transport/jrms/JRMSTransportChannel.java v 1.16

src/java/org/codehaus/activemq/transport/udp/UdpTransportChannel.java v 1.19

src/java/org/codehaus/activemq/util/FactoryFinder.java v 1.1

src/java/org/codehaus/activemq/util/IdGenerator.java v 1.1

src/test/org/codehaus/activemq/ActiveMQMessageAuditTest.java v 1.2

src/test/org/codehaus/activemq/service/BrokerTestSupport.java v 1.4

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.20

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.9

src/test/org/codehaus/activemq/transport/FactoryFinderTest.java v 1.4

src/test/org/codehaus/activemq/transport/IdGeneratorTest.java v 1.4

src/test/org/codehaus/activemq/transport/TransportChannelTestSupport.java v 1.17

src/test/org/codehaus/activemq/util/FactoryFinderTest.java v 1.1

src/test/org/codehaus/activemq/util/IdGeneratorTest.java v 1.1

moved utility code into util package
2004-08-18 14:32:59James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.16

moved utility code into util package
2004-08-18 14:31:41James Strachan

src/java/org/codehaus/activemq/transport/package.html v 1.4

moved utility code into util package
2004-08-18 14:16:04James Strachan

src/java/org/codehaus/activemq/ActiveMQConnectionFactory.java v 1.28

src/java/org/codehaus/activemq/broker/ActiveMQBeanFactory.java v 1.3

src/java/org/codehaus/activemq/broker/BrokerContainerFactory.java v 1.1

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.10

src/java/org/codehaus/activemq/spring/ActiveMQBeanDefinitionReader.java v 1.1

src/java/org/codehaus/activemq/spring/ActiveMQBeanFactory.java v 1.1

src/java/org/codehaus/activemq/spring/ActiveMQDtdResolver.java v 1.1

src/java/org/codehaus/activemq/spring/ConfigurationParseException.java v 1.1

src/java/org/codehaus/activemq/spring/Main.java v 1.1

src/java/org/codehaus/activemq/spring/SpringBrokerContainerFactory.java v 1.1

src/java/org/codehaus/activemq/spring/package.html v 1.1

src/test/org/codehaus/activemq/config/ConfigTest.java v 1.8

src/test/org/codehaus/activemq/config/howl-example.xml v 1.2

src/test/org/codehaus/activemq/config/jdbc-example.xml v 1.3

src/test/org/codehaus/activemq/config/jdbm-example.xml v 1.3

src/test/org/codehaus/activemq/config/vm-example.xml v 1.3

Moved the Spring based XML configuration file stuff into the spring package. Added the BrokerContainerFactory interface which can be set on an ActiveMQConnectionFactory. By default we don't use Spring and use the default BrokerContainerFactoryImpl, but you can use a Spring implementation if required... SpringBrokerContainerFactory is a simple POJO that can be used from within normal Spring config files or Java code to configure a broker using the XML configuration file
2004-08-18 14:15:29James Strachan

modules/container/src/java/org/codehaus/activemq/mdo/impl/MDOBeanDefinitionReader.java v 1.2

modules/container/src/test/org/codehaus/activemq/mdo/MDOConfigTest.java v 1.3

src/conf/org/codehaus/activemq/activemq-to-spring.xsl v 1.8

src/conf/org/codehaus/activemq/activemq.dtd v 1.7

src/java/org/codehaus/activemq/broker/impl/ActiveMQBeanDefinitionReader.java v 1.4

src/java/org/codehaus/activemq/broker/impl/ActiveMQDtdResolver.java v 1.3

src/java/org/codehaus/activemq/broker/impl/BrokerContainerFactoryImpl.java v 1.1

src/java/org/codehaus/activemq/broker/impl/ConfigurationParseException.java v 1.2

Moved the Spring based XML configuration file stuff into the spring package. Added the BrokerContainerFactory interface which can be set on an ActiveMQConnectionFactory. By default we don't use Spring and use the default BrokerContainerFactoryImpl, but you can use a Spring implementation if required... SpringBrokerContainerFactory is a simple POJO that can be used from within normal Spring config files or Java code to configure a broker using the XML configuration file
2004-08-18 10:40:56James Strachan

src/java/org/codehaus/activemq/ActiveMQMessageConsumer.java v 1.27

ensure messages don't get consumed if we throw an exception while consuming
2004-08-17 17:04:25James Strachan

src/conf/org/codehaus/activemq/activemq-to-spring.xsl v 1.7

src/conf/org/codehaus/activemq/activemq.dtd v 1.6

src/java/org/codehaus/activemq/store/howl/HowlPersistenceAdapter.java v 1.6

src/test/org/codehaus/activemq/config/ConfigTest.java v 1.7

src/test/org/codehaus/activemq/config/howl-example.xml v 1.1

src/test/org/codehaus/activemq/config/jdbc-example.xml v 1.2

src/test/org/codehaus/activemq/config/jdbm-example.xml v 1.2

src/test/org/codehaus/activemq/config/vm-example.xml v 1.2

added full configuration of Howl via the XML deployment descriptor
2004-08-17 15:57:32James Strachan

src/java/org/codehaus/activemq/store/howl/HowlPersistenceAdapter.java v 1.5

improved configurability of howl message store
2004-08-16 19:37:06James Strachan

src/java/org/codehaus/activemq/store/howl/HowlPersistenceAdapter.java v 1.4

improved configurability of howl message store
2004-08-16 19:27:45James Strachan

src/conf/org/codehaus/activemq/defaultHowl.properties v 1.2

src/java/org/codehaus/activemq/store/howl/HowlMessageStore.java v 1.2

src/java/org/codehaus/activemq/store/howl/HowlPersistenceAdapter.java v 1.3

src/test/org/codehaus/activemq/store/howl/HowlQueueMessageStoreTest.java v 1.2

improved configurability of howl message store
2004-08-16 18:30:53James Strachan

modules/systest/bdb/maven.xml v 1.2

modules/systest/bdb/project.properties v 1.2

modules/systest/bdb/project.xml v 1.4

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.18

another failed attempt to get the systest target to actually work. Sigh.
2004-08-16 18:00:59James Strachan

maven.xml v 1.56

modules/systest/bdb/project.xml v 1.3

attempt to get the systest target to run the system tests automatically, which doesn't quite work yet
2004-08-16 16:42:07James Strachan

src/conf/org/codehaus/activemq/activemq-to-spring.xsl v 1.6

src/conf/org/codehaus/activemq/activemq.dtd v 1.5

src/java/org/codehaus/activemq/broker/Broker.java v 1.7

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.18

src/test/org/codehaus/activemq/config/ConfigTest.java v 1.6

src/test/org/codehaus/activemq/config/example.xml v 1.6

src/test/org/codehaus/activemq/config/jdbc-example.xml v 1.1

src/test/org/codehaus/activemq/config/jdbm-example.xml v 1.1

src/test/org/codehaus/activemq/config/vm-example.xml v 1.1

added support for persistence configuration via XML configuration file
2004-08-16 15:02:05James Strachan

src/java/org/codehaus/activemq/store/bdb/BDbPersistenceAdapter.java v 1.5

src/java/org/codehaus/activemq/store/jdbm/JdbmPersistenceAdapter.java v 1.4

better start() logic
2004-08-16 14:51:33James Strachan

project.xml v 1.112

src/java/org/codehaus/activemq/ActiveMQConnectionFactory.java v 1.27

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.17

src/java/org/codehaus/activemq/store/bdb/BDbPersistenceAdapter.java v 1.4

src/java/org/codehaus/activemq/store/jdbm/JdbmPersistenceAdapter.java v 1.3

src/test/org/codehaus/activemq/store/bdb/PersistenceAdapterTest.java v 1.3

src/test/org/codehaus/activemq/usecases/DurableConsumerCloseAndReconnectTest.java v 1.5

* allow the persistence adapter to be set on a ConnectionFactory * refactored the persistence adapters to allow better spring-style configuration before they are started
2004-08-16 13:16:03James Strachan

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.17

increased timeout just to be sure we've got a failure
2004-08-16 13:04:14James Strachan

src/java/org/codehaus/activemq/broker/ActiveMQBeanFactory.java v 1.2

added static factory method
2004-08-16 12:08:21James Strachan

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.16

tidied up test even more
2004-08-16 12:04:35James Strachan

project.xml v 1.111

added Brian as a contributor
2004-08-16 11:48:48James Strachan

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.49

reduced timeout on a stop
2004-08-16 11:32:42James Strachan

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.48

reduced the timeout when closing a connection
2004-08-16 11:08:17James Strachan

src/java/org/codehaus/activemq/store/bdbn/BDbMessageStore.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java v 1.3

src/java/org/codehaus/activemq/transport/jabber/JabberWireFormat.java v 1.2

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.15

* force synchronized access to wireFormat * fixed dodgy test case * tidied some javadoc
2004-08-16 10:18:45James Strachan

src/java/org/codehaus/activemq/store/bdb/BDbMessageStore.java v 1.2

force synchronized access to wireFormat
2004-08-16 10:15:25James Strachan

src/java/org/codehaus/activemq/message/DefaultWireFormat.java v 1.13

src/java/org/codehaus/activemq/message/WireFormat.java v 1.9

src/java/org/codehaus/activemq/store/bdb/BDbPersistenceAdapter.java v 1.3

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.14

fixed bug in concurrent BDB support where we were incorrectly sharing a wireFormat across threads
2004-08-16 09:52:27James Strachan

src/java/org/codehaus/activemq/service/impl/DispatchWorker.java v 1.8

added better logging when failures occur
2004-08-14 15:29:09James Strachan

src/java/org/codehaus/activemq/broker/impl/Main.java v 1.8

stopped the broker from terminating when run as a command line executable
2004-08-14 12:02:25James Strachan

src/java/org/codehaus/activemq/transport/jgroups/JGroupsTransportChannel.java v 1.5

src/java/org/codehaus/activemq/transport/jrms/JRMSTransportChannel.java v 1.15

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.38

src/java/org/codehaus/activemq/transport/tcp/TcpTransportServerChannel.java v 1.17

src/java/org/codehaus/activemq/transport/udp/UdpTransportChannel.java v 1.18

src/java/org/codehaus/activemq/transport/vm/VmTransportChannel.java v 1.17

applied patch by Brian Guan to use daemon threads for reading transports
2004-08-13 20:26:22Hiram Chirino

src/java/org/codehaus/activemq/store/jdbc/JDBCAdapter.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/JDBCMessageStore.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/JDBCTopicMessageStore.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/SequenceGenerator.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/StatementProvider.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/adapter/CachingStatementProvider.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java v 1.2

src/java/org/codehaus/activemq/store/jdbc/adapter/DefaultStatementProvider.java v 1.2

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.8

src/test/org/codehaus/activemq/store/jdbc/JDBCTopicMessageStoreTest.java v 1.3

Implemented the durable topic side of the JDBC side of the persistence store.
2004-08-13 20:25:07Hiram Chirino

src/java/org/codehaus/activemq/transport/vm/VmTransportChannel.java v 1.16

Setting the VM Transport thread's name to something simpler so that they show up better in the logs.
2004-08-13 19:15:26James Strachan

src/java/org/codehaus/activemq/store/howl/HowlPersistenceAdapter.java v 1.2

src/java/org/codehaus/activemq/store/jdbm/JdbmPersistenceAdapter.java v 1.2

enabled howl based helper method to use howl transaction log in testing
2004-08-13 19:01:53James Strachan

maven.xml v 1.55

project.properties v 1.17

allow persistence mechanism to be easily configured for the maven server goal
2004-08-13 18:42:43James Strachan

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.18

remove cruft
2004-08-13 18:37:00James Strachan

maven.xml v 1.54

src/test/org/codehaus/activemq/store/jdbm/OrderTest.java v 1.2

removed use of enum to avoid warnings on Java 5
2004-08-13 18:36:57James Strachan

src/java/org/codehaus/activemq/ActiveMQMessageTransformation.java v 1.10

src/java/org/codehaus/activemq/jndi/JNDIReferenceFactory.java v 1.9

src/java/org/codehaus/activemq/message/ActiveMQMessage.java v 1.20

src/java/org/codehaus/activemq/store/jdbm/JdbmMessageStore.java v 1.2

src/java/org/codehaus/activemq/store/jdbm/JdbmPreparedTransactionStore.java v 1.2

src/java/org/codehaus/activemq/store/jdbm/JdbmTopicMessageStore.java v 1.2

src/java/org/codehaus/activemq/transport/composite/CompositeTransportChannelFactory.java v 1.3

src/java/org/codehaus/activemq/web/MessageServlet.java v 1.6

src/test/org/codehaus/activemq/benchmark/Consumer.java v 1.9

src/test/org/codehaus/activemq/benchmark/Producer.java v 1.11

src/test/org/codehaus/activemq/benchmark/ProducerConsumer.java v 1.4

src/test/org/codehaus/activemq/message/ActiveMQMessageTest.java v 1.4

removed use of enum to avoid warnings on Java 5
2004-08-13 18:32:21James Strachan

src/test/org/codehaus/activemq/benchmark/BenchmarkSupport.java v 1.10

updates to the benchmark test cases to allow multiple connections
2004-08-13 14:36:30James Strachan

modules/base-project.xml v 1.3

fixes for BDB test cases
2004-08-13 14:02:17James Strachan

src/java/org/codehaus/activemq/store/bdb/BDbPersistenceAdapter.java v 1.2

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.7

fixes for BDB test cases
2004-08-13 13:37:50James Strachan

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.17

src/java/org/codehaus/activemq/service/impl/PersistenceAdapterSupport.java v 1.3

src/java/org/codehaus/activemq/store/jdbc/JDBCPersistenceAdapter.java v 1.3

fixes to JDBC test cases
2004-08-13 11:37:08James Strachan

project.xml v 1.110

modules/systest/jdbc/maven.xml v 1.1

modules/systest/jdbc/project.properties v 1.1

modules/systest/jdbc/project.xml v 1.1

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.6

* fixes for BDB failing tests * added basic files for JDBC system test
2004-08-13 11:36:57James Strachan

modules/systest/jdbc/src/README.txt v 1.1

* fixes for BDB failing tests * added basic files for JDBC system test
2004-08-13 10:59:31James Strachan

src/java/org/codehaus/activemq/transport/vm/VmTransportChannel.java v 1.15

removed unnecessary log which looks like a failure
2004-08-13 10:52:23James Strachan

src/java/org/codehaus/activemq/transport/vm/VmTransportChannel.java v 1.14

cleaner shutdown logic to remove an error message on some JVMs when doing agressive start and stop of brokers in a short space of time
2004-08-13 10:07:59James Strachan

maven.xml v 1.53

src/java/org/codehaus/activemq/store/jdbc/JDBCPersistenceAdapter.java v 1.2

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.13

src/test/org/codehaus/activemq/store/jdbc/JDBCQueueMessageContainerTest.java v 1.2

src/test/org/codehaus/activemq/store/jdbc/JDBCQueueMessageStoreTest.java v 1.2

src/test/org/codehaus/activemq/store/jdbc/JDBCTopicMessageStoreTest.java v 1.2

src/test/org/codehaus/activemq/store/jdbc/PersistenceAdapterTest.java v 1.2

* minor refactor of some JDBC code to remove runtime dependency on Axion * removed unnecessary logging in tests * removed unnecessary default maven goal
2004-08-13 08:08:50James Strachan

modules/systest/bdb/maven.xml v 1.1

modules/systest/bdb/project.properties v 1.1

modules/systest/bdb/src/README.txt v 1.1

added files for BDB system test case
2004-08-13 08:00:24James Strachan

maven.xml v 1.52

modules/base-project.xml v 1.2

modules/systest/bdb/project.xml v 1.2

modules/systest/jmscts/maven.xml v 1.2

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.47

src/java/org/codehaus/activemq/ActiveMQSession.java v 1.37

src/java/org/codehaus/activemq/broker/BrokerClient.java v 1.7

src/java/org/codehaus/activemq/broker/impl/ActiveMQBeanDefinitionReader.java v 1.3

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.15

src/java/org/codehaus/activemq/broker/impl/BrokerConnectorImpl.java v 1.8

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.16

src/java/org/codehaus/activemq/store/bdb/BDbPreparedTransactionStore.java v 1.2

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.37

src/java/org/codehaus/activemq/transport/vm/VmTransportChannel.java v 1.13

src/test/log4j.properties v 1.2

src/test/org/codehaus/activemq/JmsXATransactionTestSupport.java v 1.6

src/test/org/codehaus/activemq/broker/MockBrokerClient.java v 1.17

src/test/org/codehaus/activemq/config/ConfigTest.java v 1.5

src/test/org/codehaus/activemq/tool/ConsumerTool.java v 1.7

* Tidied up the double client shutdown messages * Fixes to the config file reader when running off a JAR rather than file system * Fixed a bug in the BDB prepared transaction store * Fixed BDB system test build
2004-08-13 07:45:50James Strachan

src/java/org/codehaus/activemq/util/MessageListenerSupport.java v 1.2

Allow the process method to throw any exception
2004-08-13 07:42:19James Strachan

src/java/org/codehaus/activemq/util/MessageListenerSupport.java v 1.1

added a little helper class for writing MessageListener implementations
2004-08-12 12:42:16Hiram Chirino

src/conf/META-INF/services/org/codehaus/activemq/store/jdbc/Axion_JDBC_Driver v 1.1

src/java/org/codehaus/activemq/store/jdbc/JDBCAdapter.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/JDBCMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/JDBCPersistenceAdapter.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/JDBCPreparedTransactionStore.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/JDBCTopicMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/SequenceGenerator.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/StatementProvider.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/TransactionContext.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/package.html v 1.1

src/java/org/codehaus/activemq/store/jdbc/adapter/BlobJDBCAdapter.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/adapter/CachingStatementProvider.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/adapter/DefaultStatementProvider.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/adapter/StreamJDBCAdapter.java v 1.1

src/java/org/codehaus/activemq/store/jdbc/adapter/package.html v 1.1

src/java/org/codehaus/activemq/util/JMSExceptionHelper.java v 1.8

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.19

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.5

src/test/org/codehaus/activemq/store/jdbc/JDBCQueueMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbc/JDBCQueueMessageStoreTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbc/JDBCTopicMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbc/JDBCTopicMessageStoreTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbc/PersistenceAdapterTest.java v 1.1

Adding jdbc persistence store.
2004-08-12 12:36:27Hiram Chirino

project.xml v 1.109

Adding jdbc persistence store.
2004-08-12 11:15:33James Strachan

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.9

avoid NPE if using broker in a wierd state
2004-08-12 11:14:15James Strachan

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.8

added better error message if a broker is used before its started
2004-08-12 11:00:21James Strachan

modules/systest/bdb/project.xml v 1.1

modules/systest/jmscts/maven.xml v 1.1

modules/systest/jmscts/project.xml v 1.1

modules/systest/jmscts/config/activemq.xml v 1.1

modules/systest/jmscts/config/jmscts.policy v 1.1

modules/systest/jmscts/config/jmscts.properties v 1.1

modules/systest/jmscts/config/log4j.xml v 1.1

modules/systest/jmscts/config/providers.xml v 1.1

modules/systest/jmscts/resources/coverage-requirements.xsl v 1.1

modules/systest/jmscts/resources/coverage-tests.xsl v 1.1

modules/systest/jmscts/resources/coverage.xsl v 1.1

modules/systest/jmscts/resources/maven.css v 1.1

modules/systest/jmscts/resources/metadata.xml v 1.1

modules/systest/jmscts/resources/requirements.xml v 1.1

modules/systest/jmscts/resources/statistics.xsl v 1.1

modules/systest/jmscts/resources/tigris.css v 1.1

modules/systest/jmscts/resources/xdoc2html.xsl v 1.1

modules/systest/jmscts/src/java/org/exolab/jmscts/activemq/ActiveMQAdministrator.java v 1.1

modules/systest/jmscts/src/java/org/exolab/jmscts/activemq/ActiveMQProvider.java v 1.1

Added a first cut of the JMSCTS test cases using ActiveMQ
2004-08-12 08:55:12James Strachan

src/java/org/codehaus/activemq/transport/jgroups/JGroupsTransportChannelFactory.java v 1.3

enabled reconnection for JGroups transport
2004-08-11 16:39:43James Strachan

maven.xml v 1.51

project.properties v 1.16

another attempt to get the clover build working
2004-08-11 16:10:42James Strachan

maven.xml v 1.50

project.xml v 1.108

attempt to get clover working again
2004-08-11 16:08:13James Strachan

project.xml v 1.107

fixed javadoc groups
2004-08-11 15:56:14James Strachan

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.14

src/test/org/codehaus/activemq/store/bdb/PersistenceAdapterTest.java v 1.2

fixed bug when using BDB as the persistence engine - we were closing it down twice, DOH!
2004-08-11 15:11:53James Strachan

src/test/org/codehaus/activemq/JmsTransactionTestSupport.java v 1.6

Added test case to test for prefetch of one
2004-08-11 13:48:06James Strachan

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.36

avoid joining socket read thread as it causes long hangs :)
2004-08-11 13:27:06James Strachan

src/test/org/codehaus/activemq/JmsDurableTopicTransactionTest.java v 1.2

added explicit test for transactions with prefetch policy of 1
2004-08-11 13:15:55James Strachan

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.35

src/java/org/codehaus/activemq/transport/vm/VmTransportChannel.java v 1.12

added better shutdown logic, where we'll wait for read threads to terminate to ensure more graceful closing
2004-08-11 13:05:04James Strachan

src/java/org/codehaus/activemq/service/impl/DispatchWorker.java v 1.7

avoid null pointer exception
2004-08-11 12:29:02James Strachan

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscription.java v 1.8

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.17

src/test/org/codehaus/activemq/JmsTransactionTestSupport.java v 1.5

temporarily disabled the prefetch limiting logic which still has a few problems with transactions & rollback
2004-08-11 11:58:02James Strachan

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.16

fixes for prefetch value of 1 not working correctly with queues when inside of a transaction
2004-08-11 10:28:00James Strachan

src/test/org/codehaus/activemq/JmsTopicRequestReplyTest.java v 1.3

removed some logging stuff
2004-08-11 10:22:12James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.14

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.7

src/java/org/codehaus/activemq/service/MessageContainerManager.java v 1.7

src/java/org/codehaus/activemq/service/Subscription.java v 1.13

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageManager.java v 1.6

src/java/org/codehaus/activemq/service/impl/DispatchWorker.java v 1.6

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.15

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscription.java v 1.7

src/java/org/codehaus/activemq/service/impl/ProxyMessageContainerManager.java v 1.4

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.13

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.15

src/test/org/codehaus/activemq/JmsTransactionTestSupport.java v 1.4

src/test/org/codehaus/activemq/JmsXATransactionTestSupport.java v 1.5

src/test/org/codehaus/activemq/TestSupport.java v 1.7

Fixed issue of prefetch logic failing to deliver messages if the prefetch size is low and there are many messages consumed inside a transaction
2004-08-11 09:45:56James Strachan

maven.xml v 1.49

enabled the distro generation
2004-08-11 08:22:10James Strachan

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscription.java v 1.6

fixed bug introduced during refactoring which caused messages to be not dispatched
2004-08-11 07:51:08James Strachan

project.properties v 1.15

src/java/org/codehaus/activemq/store/vm/VMPersistenceAdapter.java v 1.2

added an executable class to the jar and added missing factory method to VMPersistenceAdapter
2004-08-10 14:09:29James Strachan

project.xml v 1.106

updated the javadoc groupings
2004-08-10 13:51:23James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.15

src/java/org/codehaus/activemq/message/ActiveMQDestination.java v 1.14

src/test/org/codehaus/activemq/JmsTopicRequestReplyTest.java v 1.2

more test cases to ensure that RPCs work whether using sync or async consume and whether creating producers dynamically or not
2004-08-10 12:03:39James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.14

updated logging message for shutdown failures
2004-08-10 11:59:23James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.13

avoided multiple shutdowns
2004-08-10 11:40:54James Strachan

src/test/org/codehaus/activemq/JmsQueueRequestReplyTest.java v 1.1

src/test/org/codehaus/activemq/JmsTopicRequestReplyTest.java v 1.1

Added request/reply test cases from Oliver Belikan
2004-08-10 10:30:24James Strachan

project.xml v 1.105

src/test/org/codehaus/activemq/store/jdbm/JdbmQueueMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbm/JdbmQueueMessageStoreTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbm/JdbmTopicMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbm/JdbmTopicMessageStoreTest.java v 1.1

src/test/org/codehaus/activemq/store/jdbm/OrderTest.java v 1.1

src/test/org/codehaus/activemq/store/vm/VMQueueMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/vm/VMTopicMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/util/TimedTransactionTemplate.java v 1.2

src/whiteboard/org/codehaus/activemq/store/bdb/StringEntityBinding.java v 1.1

src/whiteboard/org/codehaus/activemq/store/bdb/TestKeyAssigner.java v 1.1

Refactored the message persistence code to be in a separate activemq.store package hierarchy to make it easier to see what code relates to persistence and what code is dispatch or in-VM logic
2004-08-10 10:29:09James Strachan

src/java/org/codehaus/activemq/store/MessageStore.java v 1.1

src/java/org/codehaus/activemq/store/PersistenceAdapter.java v 1.1

src/java/org/codehaus/activemq/store/PreparedTransactionStore.java v 1.1

src/java/org/codehaus/activemq/store/TopicMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/package.html v 1.1

src/java/org/codehaus/activemq/store/vm/VMMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/vm/VMPersistenceAdapter.java v 1.1

src/java/org/codehaus/activemq/store/vm/VMPreparedTransactionStoreImpl.java v 1.1

src/java/org/codehaus/activemq/store/vm/VMTopicMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/vm/VMTransactionManager.java v 1.1

src/java/org/codehaus/activemq/store/vm/package.html v 1.1

src/java/org/codehaus/activemq/util/TransactionTemplate.java v 1.2

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.18

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.4

src/test/org/codehaus/activemq/service/impl/DefaultQueueListTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/BDbQueueMessageContainerInOneTransactionTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/BDbQueueMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/BDbQueueMessageStoreTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/BDbTopicMessageContainerInOneTransactionTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/BDbTopicMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/BDbTopicMessageStoreTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/OrderTest.java v 1.1

src/test/org/codehaus/activemq/store/bdb/PersistenceAdapterTest.java v 1.1

src/test/org/codehaus/activemq/store/bdbn/BDbQueueMessageContainerInOneTransactionTest.java v 1.1

src/test/org/codehaus/activemq/store/bdbn/BDbQueueMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/bdbn/BDbTopicMessageContainerInOneTransactionTest.java v 1.1

src/test/org/codehaus/activemq/store/bdbn/BDbTopicMessageContainerTest.java v 1.1

src/test/org/codehaus/activemq/store/howl/HowlQueueMessageStoreTest.java v 1.1

Refactored the message persistence code to be in a separate activemq.store package hierarchy to make it easier to see what code relates to persistence and what code is dispatch or in-VM logic
2004-08-10 10:28:36James Strachan

src/java/org/codehaus/activemq/service/MessageStore.java v 1.11

src/java/org/codehaus/activemq/service/PersistenceAdapter.java v 1.6

src/java/org/codehaus/activemq/service/PreparedTransactionStore.java v 1.4

src/java/org/codehaus/activemq/service/QueueList.java v 1.4

src/java/org/codehaus/activemq/service/TopicMessageStore.java v 1.9

src/java/org/codehaus/activemq/service/impl/DefaultQueueList.java v 1.1

src/java/org/codehaus/activemq/service/impl/DefaultQueueListEntry.java v 1.1

src/java/org/codehaus/activemq/service/impl/DispatcherImpl.java v 1.1

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.16

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainer.java v 1.13

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.14

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscriptionContainer.java v 1.5

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscriptionContainerImpl.java v 1.1

src/java/org/codehaus/activemq/service/impl/PersistenceAdapterSupport.java v 1.2

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.12

src/java/org/codehaus/activemq/service/impl/SubscriptionContainerImpl.java v 1.1

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.14

src/java/org/codehaus/activemq/service/impl/TransactionManagerImpl.java v 1.4

src/java/org/codehaus/activemq/service/impl/TransientTopicMessageContainerManager.java v 1.3

src/java/org/codehaus/activemq/service/impl/XATransactionCommand.java v 1.3

src/java/org/codehaus/activemq/store/bdb/BDbHelper.java v 1.1

src/java/org/codehaus/activemq/store/bdb/BDbMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/bdb/BDbPersistenceAdapter.java v 1.1

src/java/org/codehaus/activemq/store/bdb/BDbPreparedTransactionStore.java v 1.1

src/java/org/codehaus/activemq/store/bdb/BDbTopicMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/bdb/MockSecondaryKeyGenerator.java v 1.1

src/java/org/codehaus/activemq/store/bdb/SequenceNumberCreator.java v 1.1

src/java/org/codehaus/activemq/store/bdb/package.html v 1.1

src/java/org/codehaus/activemq/store/bdbn/BDbHelper.java v 1.1

src/java/org/codehaus/activemq/store/bdbn/BDbMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/bdbn/BDbPersistenceAdapter.java v 1.1

src/java/org/codehaus/activemq/store/bdbn/BDbTopicMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/bdbn/StringDataBinding.java v 1.1

src/java/org/codehaus/activemq/store/bdbn/StringDataFormat.java v 1.1

src/java/org/codehaus/activemq/store/bdbn/package.html v 1.1

src/java/org/codehaus/activemq/store/howl/HowlMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/howl/HowlPersistenceAdapter.java v 1.1

src/java/org/codehaus/activemq/store/howl/package.html v 1.1

src/java/org/codehaus/activemq/store/jdbm/JdbmMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/jdbm/JdbmPersistenceAdapter.java v 1.1

src/java/org/codehaus/activemq/store/jdbm/JdbmPreparedTransactionStore.java v 1.1

src/java/org/codehaus/activemq/store/jdbm/JdbmTopicMessageStore.java v 1.1

src/java/org/codehaus/activemq/store/jdbm/package.html v 1.1

Refactored the message persistence code to be in a separate activemq.store package hierarchy to make it easier to see what code relates to persistence and what code is dispatch or in-VM logic
2004-08-10 10:27:18James Strachan

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.6

Refactored the message persistence code to be in a separate activemq.store package hierarchy to make it easier to see what code relates to persistence and what code is dispatch or in-VM logic
2004-08-10 08:37:26James Strachan

src/conf/org/codehaus/activemq/activemq-to-spring.xsl v 1.5

src/conf/org/codehaus/activemq/activemq.dtd v 1.4

src/java/org/codehaus/activemq/transport/jxta/JxtaTransportServerChannel.java v 1.6

src/java/org/codehaus/activemq/transport/tcp/TcpTransportServerChannel.java v 1.16

src/test/org/codehaus/activemq/config/ConfigTest.java v 1.4

src/test/org/codehaus/activemq/config/example.xml v 1.5

Improved Spring XML config file support which allows better configuration of transport stuff
2004-08-09 21:23:12James Strachan

project.xml v 1.104

src/conf/org/codehaus/activemq/activemq-to-spring.xsl v 1.4

src/conf/org/codehaus/activemq/activemq.dtd v 1.3

src/java/org/codehaus/activemq/broker/BrokerContainer.java v 1.4

src/java/org/codehaus/activemq/transport/TransportServerChannelProvider.java v 1.12

src/test/org/codehaus/activemq/config/ConfigTest.java v 1.3

src/test/org/codehaus/activemq/config/example.xml v 1.4

src/test/org/codehaus/activemq/config/spring-test.xml v 1.1

Added better Spring XML support for creating connectors better & allowing class attributes to overload implementation classes
2004-08-09 19:58:05James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.12

attempt to avoid concurrent modification bug on shutdown thanks to idea from Niklas Gustavsson
2004-08-09 14:11:10James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.11

Added a shutdown hook for AMQ-54
2004-08-09 13:37:09James Strachan

src/test/org/codehaus/activemq/usecases/ConsumeTopicPrefetchTest.java v 1.3

used a smaller value of prefetch size by default
2004-08-09 13:22:19James Strachan

src/test/org/codehaus/activemq/usecases/DurableConsumerCloseAndReconnectTest.java v 1.4

fix to try resolve failing tests which occur on a specific linux box we have
2004-08-09 13:15:15James Strachan

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.46

src/test/org/codehaus/activemq/usecases/ConsumeQueuePrefetchTest.java v 1.2

src/test/org/codehaus/activemq/usecases/ConsumeTopicPrefetchTest.java v 1.2

commented out failing test cases until Stewey fixes them
2004-08-09 12:34:54James Strachan

src/test/org/codehaus/activemq/ProducerConsumerTestSupport.java v 1.2

src/test/org/codehaus/activemq/TestSupport.java v 1.6

src/test/org/codehaus/activemq/usecases/ConsumeExactPrefetchSizeTest.java v 1.3

src/test/org/codehaus/activemq/usecases/ConsumeQueuePrefetchTest.java v 1.1

src/test/org/codehaus/activemq/usecases/ConsumeTopicPrefetchTest.java v 1.1

added better test cases for prefetch use cases
2004-08-09 12:12:36James Strachan

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.10

src/java/org/codehaus/activemq/util/ExecutorHelper.java v 1.1

src/test/org/codehaus/activemq/util/AsyncProxyTest.java v 1.2

moved shutdown of executor objects to helper method
2004-08-09 11:52:25James Strachan

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.9

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.34

Disabled the use of async send for now and made the shutdown logic wait for pending messages on PooledExecutor queues
2004-08-09 11:18:08James Strachan

src/java/org/codehaus/activemq/service/TransactionCallback.java v 1.2

src/java/org/codehaus/activemq/service/TransactionTemplate.java v 1.2

src/test/org/codehaus/.cvsignore v 1.1

src/test/org/codehaus/activemq/util/TimedTransactionTemplate.java v 1.1

* tidied up the shutdown logic of broker/connectors * added an ExceptionTemplate which is useful for shutting things down cleanly * moved the TransactionTemplate into the util package
2004-08-09 11:17:21James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.10

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.5

src/java/org/codehaus/activemq/util/Callback.java v 1.1

src/java/org/codehaus/activemq/util/ExceptionTemplate.java v 1.1

src/java/org/codehaus/activemq/util/TransactionTemplate.java v 1.1

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.12

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.17

src/test/org/codehaus/activemq/service/TimedTransactionTemplate.java v 1.3

* tidied up the shutdown logic of broker/connectors * added an ExceptionTemplate which is useful for shutting things down cleanly * moved the TransactionTemplate into the util package
2004-08-08 08:22:28James Strachan

project.xml v 1.103

simplified dependencies using just the j2ee jar instead
2004-08-06 20:32:21James Strachan

src/java/org/codehaus/activemq/broker/BrokerConnector.java v 1.4

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.13

src/java/org/codehaus/activemq/broker/impl/BrokerConnectorImpl.java v 1.7

minor refactor to make the method name a little cleaner
2004-08-06 20:11:16James Strachan

src/test/org/codehaus/activemq/usecases/DurableConsumerCloseAndReconnectTest.java v 1.3

Made test case more rigorous testing... * new consumer + consumer who's already ack'd a message * test that lack of ack recovers properly * tests server restart or same server with consumer reconnection etc
2004-08-06 20:01:07James Strachan

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.11

src/test/org/codehaus/activemq/usecases/DurableConsumerCloseAndReconnectTest.java v 1.2

src/test/org/codehaus/activemq/usecases/QueueConsumerCloseAndReconnectTest.java v 1.1

Added test case to show queue consumption & publishing while stopping & starting consumer & broker
2004-08-06 19:32:27James Strachan

src/java/org/codehaus/activemq/service/impl/DispatchWorker.java v 1.5

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.13

src/test/org/codehaus/activemq/usecases/DurableConsumerCloseAndReconnectTest.java v 1.1

Added test case that demonstrates the use of starting a durable subscription, stopping it, publishing messages and then receiving them when a new durable subscription comes along. There was a glitch or two in the recovery code which was dispatching messages before we had sent back the receipt which caused confusion
2004-08-06 18:37:10James Strachan

src/java/org/codehaus/activemq/service/MessageContainerManager.java v 1.6

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageManager.java v 1.5

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.12

src/java/org/codehaus/activemq/service/impl/ProxyMessageContainerManager.java v 1.3

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.10

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.3

Made containers introspectable so that we can write cleaner test cases. Also fixed the bug in the BDB test case caused by a bad test case opening a container twice
2004-08-06 17:04:23James Strachan

src/java/org/codehaus/activemq/broker/BrokerClient.java v 1.6

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.12

src/java/org/codehaus/activemq/broker/impl/BrokerConnectorImpl.java v 1.6

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.4

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.11

src/test/org/codehaus/activemq/broker/MockBrokerClient.java v 1.16

Fixed some issues with disconnection of clients and recovery of subscriptions
2004-08-06 15:46:53James Strachan

src/java/org/codehaus/activemq/broker/BrokerClient.java v 1.5

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.11

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.9

src/test/org/codehaus/activemq/broker/MockBrokerClient.java v 1.15

Fixed hole where a failing channel might not close down properly (as the connection info is not present)
2004-08-06 15:09:00James Strachan

modules/ibmaio/src/java/org/codehaus/activemq/transport/ibmaio/AIOTransportChannel.java v 1.4

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.10

src/java/org/codehaus/activemq/broker/impl/BrokerConnectorImpl.java v 1.5

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.8

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.8

src/java/org/codehaus/activemq/transport/TransportChannel.java v 1.9

src/java/org/codehaus/activemq/transport/TransportServerChannelSupport.java v 1.3

src/java/org/codehaus/activemq/transport/composite/CompositeTransportChannel.java v 1.6

src/java/org/codehaus/activemq/transport/reliable/ReliableTransportChannel.java v 1.4

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.33

Added better hook to ensure we always close down BrokerClient objects to prevent using up too much resources or that clients who disconnect and come back quickly don't get rejected due to duplicate clientIDs etc.
2004-08-06 11:31:00James Strachan

maven.xml v 1.48

ensure we delete all the persistent files before every test run (as not all the tests clean down the persistent stores yet)
2004-08-06 11:14:01James Strachan

maven.xml v 1.47

project.xml v 1.102

updated the producer and consumer tools so that they can be used easily to test various QoS with queue/topic and durable/non-durable
2004-08-06 11:13:55James Strachan

src/java/org/codehaus/activemq/util/JMSExceptionHelper.java v 1.7

src/test/org/codehaus/activemq/axis/activemq-connection-factory.properties v 1.1

src/test/org/codehaus/activemq/tool/ConsumerTool.java v 1.6

src/test/org/codehaus/activemq/tool/ProducerTool.java v 1.6

src/test/org/codehaus/activemq/tool/ToolSupport.java v 1.9

updated the producer and consumer tools so that they can be used easily to test various QoS with queue/topic and durable/non-durable
2004-08-06 10:41:16James Strachan

maven.xml v 1.46

Ffixed the DC build to zap the persistence files each time we rerun the tests (which the DC build does a few times for some reason)
2004-08-06 10:38:54James Strachan

maven.xml v 1.45

project.xml v 1.101

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.7

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.3

added auto-discovery of persistence libraries; we'll try a system property (sucky alternative until the XML config file is used) or JDBM if its on the classpath else BDB. So when deployed in Geronimo, we'll use JDBM by default but a user could delete the JDBM jar and add the BDB jar to get better performance. We now can work without any persistence layer; we'll use simple RAM based persistence if neither the jars are on the classpath. Also fixed the DC build to zap the persistence files each time we rerun the tests (which the DC build does a few times for some reason) Also upgraded the Howl version
2004-08-05 18:30:03James Strachan

src/conf/META-INF/services/org.apache.axis.components.jms.JMSVendorAdapter v 1.1

added auto-discovery file so that Apache Axis will use ActiveMQ by default for any JMS traffic provided that the activemq jar is on your classpath
2004-08-05 16:30:51James Strachan

maven.xml v 1.44

attempt to fix the DC build...
2004-08-05 14:53:05James Strachan

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.32

added support for throwing of socket connections up to JMS client even when using async dispatching of socket IO
2004-08-05 14:34:04James Strachan

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.31

explicitly log any exceptions caused when trying to close the socket while reading
2004-08-05 14:24:15James Strachan

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.2

src/java/org/codehaus/activemq/service/MessageContainer.java v 1.11

src/java/org/codehaus/activemq/service/MessageContainerManager.java v 1.5

src/java/org/codehaus/activemq/service/QueueMessageContainer.java v 1.6

src/java/org/codehaus/activemq/service/Subscription.java v 1.12

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageManager.java v 1.4

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.15

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainer.java v 1.12

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.10

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscription.java v 1.5

src/java/org/codehaus/activemq/service/impl/ProxyMessageContainerManager.java v 1.2

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.9

src/java/org/codehaus/activemq/service/impl/RedeliverMessageTransactionTask.java v 1.1

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.13

src/test/org/codehaus/activemq/JmsDurableTopicTransactionTest.java v 1.1

src/test/org/codehaus/activemq/JmsResourceProvider.java v 1.4

src/test/org/codehaus/activemq/JmsTopicTransactionTest.java v 1.2

src/test/org/codehaus/activemq/JmsTransactionTestSupport.java v 1.3

Added support for proper rollback of JMS transactional message consumption & redelivery for queues and durable topics. Not currently implemented for transient topics yet but shouldn't be too hard to do.
2004-08-05 14:23:57James Strachan

src/java/org/codehaus/activemq/broker/Broker.java v 1.6

Added support for proper rollback of JMS transactional message consumption & redelivery for queues and durable topics. Not currently implemented for transient topics yet but shouldn't be too hard to do.
2004-08-05 10:30:25James Strachan

src/java/org/codehaus/activemq/message/WireFormat.java v 1.8

handle the synchronization issue Jules spotted, where we can receive messages before we've initialised the channelID yet
2004-08-04 15:15:51James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.6

src/java/org/codehaus/activemq/broker/impl/DefaultBroker.java v 1.1

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.17

src/test/org/codehaus/activemq/service/BrokerTestSupport.java v 1.3

moved the default broker implementation to a more sensible package
2004-08-04 14:22:09James Strachan

src/test/org/codehaus/activemq/JmsTransactionTestSupport.java v 1.2

tidied up the test case to ensure it doesn't fail
2004-08-04 12:58:29James Strachan

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.7

quicker shutdown logic to speed up test cases etc
2004-08-04 11:47:37James Strachan

src/test/org/codehaus/activemq/transport/tcp/TcpTransportChannelTest.java v 1.3

cleaner shutdown logic to fix some failing test cases
2004-08-04 11:24:39James Strachan

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.6

src/java/org/codehaus/activemq/transport/tcp/TcpTransportServerChannel.java v 1.15

src/test/org/codehaus/activemq/transport/TransportChannelTestSupport.java v 1.16

src/test/org/codehaus/activemq/transport/tcp/TcpTransportChannelTest.java v 1.2

cleaner shutdown logic to fix some failing test cases
2004-08-04 10:47:00James Strachan

src/test/org/codehaus/activemq/transport/TransportChannelTestSupport.java v 1.15

tidied up the shut down logic some more
2004-08-04 10:46:53James Strachan

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.5

src/java/org/codehaus/activemq/transport/TransportServerChannelSupport.java v 1.2

src/java/org/codehaus/activemq/transport/ember/EmberTransportServerChannel.java v 1.12

src/java/org/codehaus/activemq/transport/gnet/GTransportServerChannel.java v 1.10

src/java/org/codehaus/activemq/transport/jgroups/JGroupsTransportServerChannel.java v 1.2

src/java/org/codehaus/activemq/transport/jrms/JRMSTransportServerChannel.java v 1.7

src/java/org/codehaus/activemq/transport/multicast/MulticastTransportServerChannel.java v 1.12

src/java/org/codehaus/activemq/transport/tcp/TcpTransportServerChannel.java v 1.14

src/java/org/codehaus/activemq/transport/udp/UdpTransportServerChannel.java v 1.6

src/java/org/codehaus/activemq/transport/vm/VmTransportServerChannel.java v 1.6

tidied up the shut down logic some more
2004-08-04 09:55:49James Strachan

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.4

src/java/org/codehaus/activemq/transport/jgroups/JGroupsTransportChannel.java v 1.4

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.30

Applied patch kindly supplied by Charles Anthony which cleanly shuts down any PooledExecutor instances and warns if an Executor cannot be safely shutdown.
2004-08-04 09:34:25James Strachan

project.xml v 1.100

added Charles Anthony as a contributor and moved Alan into the developer list
2004-08-04 09:32:31James Strachan

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageManager.java v 1.3

fixed typeo kindly found by Charles Anthony
2004-08-04 09:25:40James Strachan

src/java/org/codehaus/activemq/axis/ActiveMQVendorAdapter.java v 1.3

added back the Apache Axis adapter
2004-08-04 09:02:02James Strachan

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.9

rolled back reformat
2004-08-04 08:12:32James Strachan

maven.xml v 1.43

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.8

src/java/org/codehaus/activemq/message/ConnectionInfo.java v 1.7

src/test/org/codehaus/activemq/benchmark/BenchmarkSupport.java v 1.9

src/test/org/codehaus/activemq/benchmark/Consumer.java v 1.8

src/test/org/codehaus/activemq/benchmark/Producer.java v 1.10

tidied up the various options in the benchmark test so we can easily handle lots of different use cases, persistence on/off, queue/topic, different message sizes etc
2004-08-04 06:48:44James Strachan

project.xml v 1.99

disabled all multicast test cases for now as they don't work on the DC build (we should try figure out why)
2004-08-04 06:36:08James Strachan

project.xml v 1.98

disabled all multicast test cases for now as they don't work on the DC build (we should try figure out why)
2004-08-04 06:20:19James Strachan

modules/ibmaio/src/java/org/codehaus/activemq/transport/ibmaio/AIOTransportChannel.java v 1.3

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.45

src/java/org/codehaus/activemq/ActiveMQConnectionFactory.java v 1.26

src/java/org/codehaus/activemq/filter/NoLocalFilter.java v 1.3

src/java/org/codehaus/activemq/message/ActiveMQMessage.java v 1.19

src/java/org/codehaus/activemq/message/WireFormat.java v 1.7

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.3

src/java/org/codehaus/activemq/transport/TransportChannel.java v 1.8

src/java/org/codehaus/activemq/transport/udp/UdpTransportChannel.java v 1.17

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.11

src/test/org/codehaus/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java v 1.11

src/test/org/codehaus/activemq/transport/TransportChannelTestSupport.java v 1.14

src/test/org/codehaus/activemq/transport/jgroups/JGroupsTwoBrokerTest.java v 1.1

src/test/org/codehaus/activemq/transport/jrms/JRMSTwoBrokerTest.java v 1.1

src/test/org/codehaus/activemq/transport/multicast/MockConnectionFactory.java v 1.1

src/test/org/codehaus/activemq/transport/multicast/MulticastTwoBrokerTest.java v 1.1

Fixed bug that was causing loops of messages to be continuously resent when using multicast based transports. Turns out the culprit was a dodgy clone() implementation in ActiveMQMessage Added test cases to ensure this bug never happens again!
2004-08-03 10:28:04James Strachan

src/test/org/codehaus/activemq/benchmark/Producer.java v 1.9

allow the message size to be parameterized
2004-08-03 09:26:50James Strachan

src/java/org/codehaus/activemq/axis/ActiveMQVendorAdapter.java v 1.2

temporarly removal of Axis support
2004-08-03 08:36:41James Strachan

maven.xml v 1.42

project.xml v 1.97

src/java/org/codehaus/activemq/axis/ActiveMQVendorAdapter.java v 1.1

src/java/org/codehaus/activemq/axis/package.html v 1.1

Added initial support for Apache Axis so that we can drop right into Axis deployments
2004-08-03 08:19:58James Strachan

src/java/org/codehaus/activemq/transport/reliable/ReliableTransportChannel.java v 1.3

fixed schoolboy error I just introduced
2004-08-03 07:50:07James Strachan

src/java/org/codehaus/activemq/transport/reliable/ReliableTransportChannel.java v 1.2

avoided recursion when failures occur as we'll eventually run out of stack RAM :)
2004-08-03 07:44:42James Strachan

src/test/org/codehaus/activemq/usecases/ConsumeExactPrefetchSizeTest.java v 1.2

enabled what used to be a failing test
2004-08-02 16:21:26James Strachan

src/test/org/codehaus/activemq/benchmark/BenchmarkSupport.java v 1.8

src/test/org/codehaus/activemq/benchmark/Consumer.java v 1.7

src/test/org/codehaus/activemq/benchmark/Producer.java v 1.8

src/test/org/codehaus/activemq/benchmark/ProducerConsumer.java v 1.3

used correct flag for setting whether topics or queues are used
2004-08-02 15:54:39James Strachan

maven.xml v 1.41

fixed typeo
2004-08-02 03:36:52Hiram Chirino

.cvsignore v 1.5

Ignore the ActiveMQ data directory that is created when you run activemq.
2004-08-02 03:35:28Hiram Chirino

src/conf/org/codehaus/activemq/activemq-to-spring.xsl v 1.3

src/conf/org/codehaus/activemq/activemq.dtd v 1.2

src/test/org/codehaus/activemq/config/example.xml v 1.3

Config Testcase was failing. The BrokerContainerImpl now requires a broker name. Updated the config dtd and spring xslt converter to pass in the broker name. The original error message was; ------------- ---------------- --------------- Testcase: testConfig(org.codehaus.activemq.config.ConfigTest): Caused an ERROR Could not instantiate class [org.codehaus.activemq.broker.impl.BrokerContainerImpl]; Is it an interface or an abstract class? Does it have a no-arg constructor?; nested exception is java.lang.InstantiationException: org.codehaus.activemq.broker.impl.BrokerContainerImpl org.springframework.beans.FatalBeanException: Could not instantiate class [org.codehaus.activemq.broker.impl.BrokerContainerImpl]; Is it an interface or an abstract class? Does it have a no-arg constructor?; nested exception is java.lang.InstantiationException: org.codehaus.activemq.broker.impl.BrokerContainerImpl java.lang.InstantiationException: org.codehaus.activemq.broker.impl.BrokerContainerImpl at java.lang.Class.newInstance0(Class.java:293) at java.lang.Class.newInstance(Class.java:261) at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:46) at org.springframework.beans.BeanWrapperImpl.<init>(BeanWrapperImpl.java:168) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:184) at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:159) at org.codehaus.activemq.config.ConfigTest.testConfig(ConfigTest.java:42) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
2004-08-02 02:25:46Hiram Chirino

src/test/org/codehaus/activemq/ra/ManagedConnectionFactoryTest.java v 1.4

src/test/org/codehaus/activemq/ra/ManagedConnectionTest.java v 1.4

Refactoring broke test. Resource Adapter must be started before test can work.
2004-08-02 02:23:47Hiram Chirino

src/test/org/codehaus/activemq/ra/ManagedConnectionFactoryTest.java v 1.3

Refactoring broke test. Resource Adapter must be started before test can work.
2004-08-02 02:22:53Hiram Chirino

project.properties v 1.14

Added the src/conf directory to the eclispe classpath so that junit tests work inside eclipse.
2004-08-01 21:42:58Alan D. Cabrera

src/java/org/codehaus/activemq/transport/gnet/GTransportChannelFactory.java v 1.8

src/java/org/codehaus/activemq/transport/gnet/GTransportServerChannelFactory.java v 1.7

There should always be more than one thread in a communications thread pool.
2004-08-01 21:03:05Alan D. Cabrera

src/java/org/codehaus/activemq/transport/gnet/GTransportChannel.java v 1.14

Updated interface implementation.
2004-08-01 03:15:11Hiram Chirino

modules/itest-client/src/test/org/activemq/itests/InboundResourceAdapterTest.java v 1.5

modules/itest-client/src/test/org/activemq/itests/OutboundResourceAdapterTest.java v 1.4

modules/itest-server/src/java/org/codehaus/activemq/itest/ejb/MessengerBean.java v 1.5

Better tests.
2004-08-01 03:08:31Hiram Chirino

src/java/org/codehaus/activemq/ra/ActiveMQConnectionFactory.java v 1.6

src/java/org/codehaus/activemq/ra/ActiveMQManagedConnection.java v 1.14

src/java/org/codehaus/activemq/ra/ActiveMQManagedConnectionFactory.java v 1.7

src/java/org/codehaus/activemq/ra/ActiveMQResourceAdapter.java v 1.11

src/rar/META-INF/geronimo-ra.xml v 1.9

src/rar/META-INF/ra.xml v 1.6

src/test/org/codehaus/activemq/ra/ManagedConnectionFactoryTest.java v 1.2

src/test/org/codehaus/activemq/ra/ManagedConnectionTest.java v 1.3

The outbound managed connections now use the resource adapter's connection. That is that a single jms connection is used for all inbound and outbound operations.
2004-08-01 02:26:03David Jencks

modules/itest-client/src/test/org/activemq/itests/InboundResourceAdapterTest.java v 1.4

modules/itest-client/src/test/org/activemq/itests/OutboundResourceAdapterTest.java v 1.3

make inbound test slightly more realistic until it works, and clean up outbound test
2004-08-01 02:24:41David Jencks

src/java/org/codehaus/activemq/ActiveMQMessageConsumer.java v 1.26

src/java/org/codehaus/activemq/ActiveMQSession.java v 1.36

Avoid a concurrent modification exception by an ugly hack. Experts, PLEASE FIX THIS
2004-08-01 02:23:03David Jencks

src/java/org/codehaus/activemq/ActiveMQXASession.java v 1.8

Better xid/flag matching logic
2004-08-01 02:21:15David Jencks

src/java/org/codehaus/activemq/ra/ActiveMQPollingEndpointWorker.java v 1.5

improve logging messages
2004-08-01 02:20:14David Jencks

src/java/org/codehaus/activemq/ra/ActiveMQResourceAdapter.java v 1.10

only shut down the connection if it exists
2004-08-01 02:18:10David Jencks

src/java/org/codehaus/activemq/ActiveMQConnectionFactory.java v 1.25

src/java/org/codehaus/activemq/ActiveMQXAConnection.java v 1.6

src/java/org/codehaus/activemq/broker/Broker.java v 1.5

src/java/org/codehaus/activemq/broker/impl/BrokerConnectorImpl.java v 1.4

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.5

src/java/org/codehaus/activemq/broker/impl/Main.java v 1.7

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.16

src/rar/META-INF/geronimo-ra.xml v 1.8

src/test/org/codehaus/activemq/service/BrokerTestSupport.java v 1.2

Since we rely on brokerName to distinguish rms, lets actually give the broker a name
2004-07-31 21:11:00David Jencks

src/java/org/codehaus/activemq/ra/ActiveMQAsfEndpointWorker.java v 1.3

clean up imports etc
2004-07-31 21:09:41David Jencks

src/java/org/codehaus/activemq/ra/ActiveMQPollingEndpointWorker.java v 1.4

src/java/org/codehaus/activemq/ra/CircularQueue.java v 1.1

src/test/org/codehaus/activemq/ra/CircularQueueTest.java v 1.1

learn to count
2004-07-31 09:54:59stewie

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.29

Changed Thread priorities - the higher the further downstream you go
2004-07-31 03:51:30James Strachan

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.28

added check for interupted exception while reading from socket to fix Charles Anthony's AS/400 issue. We need to double check this is totally correct - I think so
2004-07-30 20:46:55stewie

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.44

changed default timeout for closing to 60 secs ...
2004-07-30 19:59:37stewie

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.27

make sure close is guarded by sync
2004-07-30 19:56:13stewie

src/java/org/codehaus/activemq/message/util/WireByteArrayOutputStream.java v 1.2

added reset() to take away synchonization
2004-07-30 19:55:24stewie

src/java/org/codehaus/activemq/message/DefaultWireFormat.java v 1.12

synchronized readPacket
2004-07-30 19:48:54stewie

src/java/org/codehaus/activemq/ActiveMQPrefetchPolicy.java v 1.7

Changed queue prefetch to 1o - to emphasise some weird behaviour - and also to make queues more robust (less to replay!)
2004-07-30 19:47:21stewie

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.43

Changed default timeout on a close to 10 secs
2004-07-30 19:32:37Hiram Chirino

src/java/org/codehaus/activemq/ra/ActiveMQManagedConnection.java v 1.13

better
2004-07-30 18:32:42Hiram Chirino

src/test/org/codehaus/activemq/service/impl/XATransactionTest.java v 1.2

More XID tests
2004-07-30 18:32:05Hiram Chirino

src/java/org/codehaus/activemq/ra/ActiveMQManagedConnection.java v 1.12

src/java/org/codehaus/activemq/ra/JMSConnectionProxy.java v 1.8

src/java/org/codehaus/activemq/ra/JMSSessionProxy.java v 1.8

Better session handling.
2004-07-30 17:56:21Hiram Chirino

modules/itest-server/src/ejb/META-INF/ejb-jar.xml v 1.4

test transacted receive.
2004-07-30 17:03:51Hiram Chirino

src/java/org/codehaus/activemq/message/ActiveMQXid.java v 1.7

XID was not serializing to string correctly.
2004-07-30 02:55:30James Strachan

src/java/org/codehaus/activemq/transport/composite/CompositeTransportChannel.java v 1.5

src/java/org/codehaus/activemq/web/WebClient.java v 1.11

tidied up some warnings that findbugs found
2004-07-30 02:09:19James Strachan

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.12

fixed bug I introduced into subscription
2004-07-30 02:01:06Hiram Chirino

src/rar/META-INF/geronimo-ra.xml v 1.7

Going XA with the ra config.
2004-07-30 01:57:42Hiram Chirino

modules/itest-client/src/test/org/activemq/itests/InboundResourceAdapterTest.java v 1.3

More tests
2004-07-30 01:52:52Hiram Chirino

src/java/org/codehaus/activemq/ActiveMQConnectionConsumer.java v 1.7

src/java/org/codehaus/activemq/ActiveMQConnectionFactory.java v 1.24

src/java/org/codehaus/activemq/ra/ActiveMQAsfEndpointWorker.java v 1.2

src/java/org/codehaus/activemq/ra/ActiveMQBaseEndpointWorker.java v 1.2

src/java/org/codehaus/activemq/ra/ActiveMQPollingEndpointWorker.java v 1.3

- Reimplemented the Polling Endpoint Worker - ASF endpoint work also works.. but not as good as the polling worker - A ConnectionConsumer can now queue up messages that can be received() - The embeded brokers are now not started or stoped if there is a vm://localhost local connector allready running in the VM.
2004-07-29 21:32:00stewie

src/test/org/codehaus/activemq/jndi/AdminObjectTest.java v 1.2

Fixed getting retrieving from JNDI repository correctly
2004-07-29 21:31:42stewie

src/java/org/codehaus/activemq/jndi/JNDIReferenceFactory.java v 1.8

Fixed getting retrieving from JNDI repository correctly
2004-07-29 01:05:32Hiram Chirino

src/java/org/codehaus/activemq/ra/ActiveMQPollingEndpointWorker.java v 1.2

src/rar/META-INF/geronimo-ra.xml v 1.6

src/rar/META-INF/ra.xml v 1.5

src/test/org/codehaus/activemq/JmsResourceProvider.java v 1.3

The inbound resource adapter is working again.
2004-07-29 01:03:59Hiram Chirino

modules/itest-client/src/test/org/activemq/itests/InboundResourceAdapterTest.java v 1.2

modules/itest-client/src/test/org/activemq/itests/JmsResourceProvider.java v 1.2

modules/itest-ear/project.properties v 1.2

modules/itest-server/src/java/org/codehaus/activemq/itest/ejb/MDBTransferBean.java v 1.3

modules/itest-server/src/java/org/codehaus/activemq/itest/ejb/MessengerBean.java v 1.4

modules/itest-server/src/java/org/codehaus/activemq/itest/ejb/MessengerObject.java v 1.3

The inbound resource adapter is working again.
2004-07-28 16:14:21Hiram Chirino

project.xml v 1.96

Better rar packaging.
2004-07-27 22:07:04James Strachan

src/java/org/codehaus/activemq/web/WebClient.java v 1.10

remove more findbugs warnings :)
2004-07-27 22:04:55James Strachan

src/java/org/codehaus/activemq/message/ActiveMQMessage.java v 1.18

src/java/org/codehaus/activemq/message/ActiveMQStreamMessage.java v 1.7

removed unnecessary boolean construction
2004-07-27 22:00:24James Strachan

src/java/org/codehaus/activemq/web/MessageServletSupport.java v 1.8

fixed null pointer bug
2004-07-27 19:17:33James Strachan

src/java/org/codehaus/activemq/message/ActiveMQMapMessage.java v 1.6

removed unnecessary constructor
2004-07-27 18:31:43James Strachan

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.11

added more synchronization
2004-07-27 18:24:12James Strachan

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.10

added more synchronization
2004-07-27 17:48:44James Strachan

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.9

use temporary object rather than shared state
2004-07-27 17:43:43James Strachan

src/java/org/codehaus/activemq/service/impl/DispatchWorker.java v 1.4

minor tweek to put state change inside sync lock
2004-07-27 15:34:02James Strachan

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.10

feeble attempt at setting the timeout high enough to get more greens :)
2004-07-27 15:31:22James Strachan

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.2

fixed bug in BDB recovery of durable topics
2004-07-27 00:20:29James Strachan

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.8

made more methods synchronized to try avoid some strange queue based behaviour
2004-07-27 00:11:47James Strachan

maven.xml v 1.40

src/conf/org/codehaus/activemq/defaultHowl.properties v 1.1

src/java/org/codehaus/activemq/ActiveMQSession.java v 1.35

src/java/org/codehaus/activemq/message/ConsumerInfo.java v 1.8

src/java/org/codehaus/activemq/message/DefaultWireFormat.java v 1.11

src/java/org/codehaus/activemq/message/WireFormat.java v 1.6

src/java/org/codehaus/activemq/service/MessageIdentity.java v 1.6

src/java/org/codehaus/activemq/service/SubscriberEntry.java v 1.1

src/java/org/codehaus/activemq/service/TopicMessageStore.java v 1.8

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.14

src/java/org/codehaus/activemq/service/impl/MessageEntry.java v 1.3

src/java/org/codehaus/activemq/util/JMSExceptionHelper.java v 1.6

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.9

src/test/org/codehaus/activemq/JmsTopicSendReceiveSubscriberTest.java v 1.1

src/test/org/codehaus/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java v 1.10

src/test/org/codehaus/activemq/message/ActiveMQTextMessageTest.java v 1.2

src/test/org/codehaus/activemq/message/PacketTestSupport.java v 1.4

src/test/org/codehaus/activemq/message/ProducerInfoReaderTest.java v 1.2

src/test/org/codehaus/activemq/message/ReceiptReaderTest.java v 1.3

src/test/org/codehaus/activemq/message/SessionInfoTest.java v 1.1

src/test/org/codehaus/activemq/message/TransactionInfoReaderTest.java v 1.4

src/test/org/codehaus/activemq/message/XATransactionInfoReaderTest.java v 1.5

src/test/org/codehaus/activemq/tool/ConsumerTool.java v 1.5

src/test/org/codehaus/activemq/tool/ProducerTool.java v 1.5

src/test/org/codehaus/activemq/tool/ToolSupport.java v 1.8

delete the persistent ActiveMQ directory when new builds are done and added durable flag to benchmarks
2004-07-26 12:24:47Hiram Chirino

modules/itest-server/src/ejb/META-INF/ejb-jar.xml v 1.3

modules/itest-server/src/java/org/codehaus/activemq/itest/ejb/MDBTransferBean.java v 1.2

modules/itest-server/src/java/org/codehaus/activemq/itest/ejb/MessengerBean.java v 1.3

Changed the queue names to make more sense.
2004-07-26 12:22:47Hiram Chirino

modules/itest-client/project.xml v 1.3

modules/itest-client/src/test/org/activemq/itests/InboundResourceAdapterTest.java v 1.1

modules/itest-client/src/test/org/activemq/itests/JmsResourceProvider.java v 1.1

modules/itest-client/src/test/org/activemq/itests/OutboundResourceAdapterTest.java v 1.2

modules/itest-client/src/test/org/activemq/itests/log4j.properties v 1.1

Added a inbound resource adpter test.. it's still not passing :(
2004-07-26 12:20:51Hiram Chirino

src/rar/META-INF/geronimo-ra.xml v 1.5

src/rar/META-INF/ra.xml v 1.4

Using the vm transport since the broker is in the save vm. Renamed some queues.
2004-07-26 12:19:12Hiram Chirino

src/java/org/codehaus/activemq/ra/ActiveMQAsfEndpointWorker.java v 1.1

src/java/org/codehaus/activemq/ra/ActiveMQBaseEndpointWorker.java v 1.1

src/java/org/codehaus/activemq/ra/ActiveMQEndpointWorker.java v 1.6

src/java/org/codehaus/activemq/ra/ActiveMQManagedConnection.java v 1.11

src/java/org/codehaus/activemq/ra/ActiveMQPollingEndpointWorker.java v 1.1

src/java/org/codehaus/activemq/ra/ActiveMQResourceAdapter.java v 1.9

We now have 2 different types of Endpoint Workers.
2004-07-26 12:17:36Hiram Chirino

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageContainer.java v 1.2

While testing, I found my CPU getting pegged at 100%. Found that queue was closed but we were still started. We basicly had a busy loop in the run method.
2004-07-26 04:33:10James Strachan

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.15

src/test/org/codehaus/activemq/service/impl/XATransactionTest.java v 1.1

added test case & patch to use latest transaction manager & prepared transaction store
2004-07-25 22:02:17stewie

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.2

Added doAsyncSend() method - which can be overriden by Transports that might use a ThreadedExecutor (TcpTransportChanne) This is to get around some timing issues that have been introduced
2004-07-25 22:00:40stewie

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.26

If using a pooled executor - check the Channel isn't closed before sending a Packet
2004-07-25 21:43:41James Strachan

src/java/org/codehaus/activemq/service/impl/TransactionTemplate.java v 1.2

moved to service package
2004-07-25 21:39:39James Strachan

src/java/org/codehaus/activemq/service/TransactionCallback.java v 1.1

src/java/org/codehaus/activemq/service/TransactionTemplate.java v 1.1

src/java/org/codehaus/activemq/service/impl/MessageAckTransactionTask.java v 1.1

src/java/org/codehaus/activemq/service/impl/PacketTransactionTask.java v 1.1

src/java/org/codehaus/activemq/service/impl/SendMessageTransactionTask.java v 1.1

src/java/org/codehaus/activemq/util/SerializationHelper.java v 1.1

src/test/org/codehaus/activemq/message/MockXid.java v 1.1

src/test/org/codehaus/activemq/test/SerializationTestSupport.java v 1.1

test case and implementation of recoverable XA prepare transactions
2004-07-25 21:35:07James Strachan

src/java/org/codehaus/activemq/message/ActiveMQXid.java v 1.6

src/java/org/codehaus/activemq/service/PreparedTransactionStore.java v 1.3

src/java/org/codehaus/activemq/service/Transaction.java v 1.4

src/java/org/codehaus/activemq/service/TransactionManager.java v 1.5

src/java/org/codehaus/activemq/service/TransactionTask.java v 1.3

src/java/org/codehaus/activemq/service/impl/AbstractTransaction.java v 1.4

src/java/org/codehaus/activemq/service/impl/TransactionManagerImpl.java v 1.3

src/java/org/codehaus/activemq/service/impl/XATransactionCommand.java v 1.2

src/java/org/codehaus/activemq/util/JMSExceptionHelper.java v 1.5

src/test/org/codehaus/activemq/JmsXATransactionTestSupport.java v 1.4

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.16

src/test/org/codehaus/activemq/service/TimedTransactionTemplate.java v 1.2

test case and implementation of recoverable XA prepare transactions
2004-07-25 16:06:56stewie

src/java/org/codehaus/activemq/transport/tcp/TcpTransportServerChannel.java v 1.13

Only produce warning message abour accept() failing if not closed
2004-07-25 16:05:29stewie

src/java/org/codehaus/activemq/service/impl/DispatchWorker.java v 1.3

check not stopped before polling a containerManager
2004-07-25 16:04:33stewie

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.7

send back receipt if closing a Client before closing
2004-07-25 16:03:05stewie

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.42

removeCapacityEventListener on close()
2004-07-25 07:09:25stewie

src/java/org/codehaus/activemq/message/DefaultWireFormat.java v 1.10

tidied up imports
2004-07-25 07:07:55stewie

src/java/org/codehaus/activemq/message/DefaultWireFormat.java v 1.9

src/java/org/codehaus/activemq/message/util/WireByteArrayInputStream.java v 1.1

src/java/org/codehaus/activemq/message/util/WireByteArrayOutputStream.java v 1.1

Some minor optimzations for data being read/written
2004-07-24 11:17:49stewie

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageManager.java v 1.2

Fixed school boy error cast exception
2004-07-24 10:50:45stewie

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.25

tuned a little for consumers :-)
2004-07-24 09:26:07stewie

src/java/org/codehaus/activemq/message/CapacityInfo.java v 1.2

BoundedMemory Usage and flow control
2004-07-24 09:25:06stewie

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.41

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.24

BoundedMemory Usage and flow control
2004-07-24 09:24:06stewie

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.6

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.4

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.14

BoundedMemory Usage and flow control
2004-07-24 09:23:05stewie

src/java/org/codehaus/activemq/message/util/MemoryBoundedQueueManager.java v 1.2

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageContainer.java v 1.1

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicBoundedMessageManager.java v 1.1

src/java/org/codehaus/activemq/service/boundedvm/TransientTopicSubscription.java v 1.1

BoundedMemory Usage and flow control
2004-07-23 18:11:28James Strachan

src/java/org/codehaus/activemq/service/TransactionManager.java v 1.4

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.13

src/java/org/codehaus/activemq/service/impl/TransactionManagerImpl.java v 1.2

src/java/org/codehaus/activemq/service/impl/XATransactionCommand.java v 1.1

refactorings ready for full XA prepare persistence
2004-07-23 17:13:43James Strachan

src/java/org/codehaus/activemq/message/ActiveMQXid.java v 1.5

src/java/org/codehaus/activemq/service/PersistenceAdapter.java v 1.5

src/java/org/codehaus/activemq/service/PreparedTransactionStore.java v 1.2

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.12

added the hooks to allow clean implementations of the PreparedTransactionStore and turned on support for JDBM by default
2004-07-23 15:56:19James Strachan

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.13

added more synchronized methods to avoid possible bizarre concurrent behaviour
2004-07-23 15:47:43James Strachan

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.8

attempt to fix really slow test cases
2004-07-23 14:44:29James Strachan

src/java/org/codehaus/activemq/message/MessageAck.java v 1.8

src/java/org/codehaus/activemq/service/PreparedTransactionStore.java v 1.1

src/java/org/codehaus/activemq/service/Transaction.java v 1.3

src/java/org/codehaus/activemq/service/impl/TransactionManagerImpl.java v 1.1

refactorings to make it easy to implement a persistent PreparedTransactionStore to allow full recovery in XA with full persistence
2004-07-23 13:32:00James Strachan

project.xml v 1.95

* refactorings to be able to more easily implement a transaction log based message store * removed some old crufty classes
2004-07-23 13:31:59James Strachan

src/java/org/codehaus/activemq/service/MessageContainer.java v 1.10

src/java/org/codehaus/activemq/service/MessageStore.java v 1.10

src/java/org/codehaus/activemq/service/PersistenceAdapter.java v 1.4

src/java/org/codehaus/activemq/service/Subscription.java v 1.11

src/java/org/codehaus/activemq/service/TopicMessageStore.java v 1.7

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.12

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainer.java v 1.11

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.9

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscription.java v 1.4

src/java/org/codehaus/activemq/service/impl/Journal.java v 1.3

src/java/org/codehaus/activemq/service/impl/JournalMessageContainerManager.java v 1.3

src/java/org/codehaus/activemq/service/impl/MessagePointer.java v 1.3

src/java/org/codehaus/activemq/service/impl/PersistenceAdapterSupport.java v 1.1

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.8

src/java/org/codehaus/activemq/service/impl/RamJournal.java v 1.3

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.7

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.15

src/test/org/codehaus/activemq/service/QueueMessageStoreTestSupport.java v 1.3

* refactorings to be able to more easily implement a transaction log based message store * removed some old crufty classes
2004-07-23 08:33:39James Strachan

src/test/org/codehaus/activemq/test/SendReceiveTest.java v 1.3

increased timeout in case running on a slow box
2004-07-23 05:42:33James Strachan

src/java/org/codehaus/activemq/service/MessageStore.java v 1.9

src/java/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.4

src/java/org/codehaus/activemq/service/TopicMessageStore.java v 1.6

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.11

src/test/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.1

moved unnecessary method to TopicMessageStore and also moved test code to the test directory :)
2004-07-23 04:48:36James Strachan

src/java/org/codehaus/activemq/service/impl/TransactionTemplate.java v 1.1

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.14

src/test/org/codehaus/activemq/service/TimedTransactionTemplate.java v 1.1

added transaction template for easier working with PersistenceAdapters and fixed a couple of BDB issues
2004-07-22 18:58:59James Strachan

project.properties v 1.13

changed the default persistence location
2004-07-22 16:24:26James Strachan

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.11

disabled JDBM again
2004-07-22 15:46:48stewie

src/java/org/codehaus/activemq/ActiveMQMessageConsumer.java v 1.25

src/java/org/codehaus/activemq/ActiveMQSession.java v 1.34

src/java/org/codehaus/activemq/broker/Broker.java v 1.4

src/java/org/codehaus/activemq/broker/BrokerClient.java v 1.4

src/java/org/codehaus/activemq/broker/BrokerConnector.java v 1.3

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.5

src/java/org/codehaus/activemq/broker/impl/BrokerConnectorImpl.java v 1.3

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.3

src/java/org/codehaus/activemq/message/util/SpooledBoundedPacketQueue.java v 1.3

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.10

src/test/org/codehaus/activemq/broker/MockBrokerClient.java v 1.14

Added support for flow control and reliability
2004-07-22 15:36:30James Strachan

modules/ibmaio/src/java/org/codehaus/activemq/transport/ibmaio/AIOTransportChannel.java v 1.2

src/java/org/codehaus/activemq/AlreadyClosedException.java v 1.1

src/java/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.3

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.9

src/test/org/codehaus/activemq/service/QueueMessageStoreTestSupport.java v 1.2

src/test/org/codehaus/activemq/service/SimpleTopicBrokerTest.java v 1.3

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.8

re-enabled JDBM as the default persistence fixed some failing tests added better handling of use-after-closed to JDBM stuff fixed a compile error in asyncio
2004-07-22 14:23:23stewie

src/conf/META-INF/services/org/codehaus/activemq/transport/reliable v 1.1

Added reliable transport
2004-07-22 14:05:07James Strachan

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.8

disabled persistence temporarily
2004-07-22 13:52:21stewie

src/java/org/codehaus/activemq/ActiveMQMessageConsumer.java v 1.24

src/java/org/codehaus/activemq/ActiveMQPrefetchPolicy.java v 1.6

src/java/org/codehaus/activemq/ActiveMQSession.java v 1.33

src/java/org/codehaus/activemq/broker/Broker.java v 1.3

src/java/org/codehaus/activemq/broker/BrokerClient.java v 1.3

src/java/org/codehaus/activemq/broker/BrokerConnector.java v 1.2

src/java/org/codehaus/activemq/broker/BrokerContainer.java v 1.3

src/java/org/codehaus/activemq/broker/impl/BrokerConnectorImpl.java v 1.2

src/java/org/codehaus/activemq/broker/impl/BrokerContainerImpl.java v 1.2

src/java/org/codehaus/activemq/capacity/BasicCapacityMonitor.java v 1.2

src/java/org/codehaus/activemq/capacity/CapacityMonitor.java v 1.3

src/java/org/codehaus/activemq/capacity/CapacityMonitorEvent.java v 1.2

src/java/org/codehaus/activemq/capacity/CapacityMonitorEventListener.java v 1.2

src/java/org/codehaus/activemq/capacity/DelegateCapacityMonitor.java v 1.1

src/java/org/codehaus/activemq/message/AbstractPacket.java v 1.10

src/java/org/codehaus/activemq/message/CapacityInfo.java v 1.1

src/java/org/codehaus/activemq/message/CapacityInfoReader.java v 1.1

src/java/org/codehaus/activemq/message/CapacityInfoRequest.java v 1.1

src/java/org/codehaus/activemq/message/CapacityInfoRequestReader.java v 1.1

src/java/org/codehaus/activemq/message/CapacityInfoRequestWriter.java v 1.1

src/java/org/codehaus/activemq/message/CapacityInfoWriter.java v 1.1

src/java/org/codehaus/activemq/message/DefaultWireFormat.java v 1.8

src/java/org/codehaus/activemq/message/Packet.java v 1.10

src/java/org/codehaus/activemq/message/Receipt.java v 1.8

src/java/org/codehaus/activemq/message/ReceiptReader.java v 1.7

src/java/org/codehaus/activemq/message/ReceiptWriter.java v 1.8

src/java/org/codehaus/activemq/message/util/BoundedPacketQueue.java v 1.2

src/java/org/codehaus/activemq/message/util/MemoryBoundedQueue.java v 1.2

src/java/org/codehaus/activemq/message/util/SpooledBoundedPacketQueue.java v 1.2

src/java/org/codehaus/activemq/transport/AbstractTransportChannel.java v 1.1

src/java/org/codehaus/activemq/transport/TransportChannel.java v 1.7

src/java/org/codehaus/activemq/transport/TransportStatusEvent.java v 1.1

src/java/org/codehaus/activemq/transport/TransportStatusEventListener.java v 1.1

src/java/org/codehaus/activemq/transport/composite/CompositeTransportChannel.java v 1.4

src/java/org/codehaus/activemq/transport/composite/CompositeTransportChannelFactory.java v 1.2

src/java/org/codehaus/activemq/transport/ember/EmberTransportChannel.java v 1.13

src/java/org/codehaus/activemq/transport/gnet/GTransportChannel.java v 1.13

src/java/org/codehaus/activemq/transport/jgroups/JGroupsTransportChannel.java v 1.3

src/java/org/codehaus/activemq/transport/jrms/JRMSTransportChannel.java v 1.14

src/java/org/codehaus/activemq/transport/reliable/ReliableTransportChannel.java v 1.1

src/java/org/codehaus/activemq/transport/reliable/ReliableTransportChannelFactory.java v 1.1

src/java/org/codehaus/activemq/transport/reliable/SMLCGRandom.java v 1.1

src/java/org/codehaus/activemq/transport/tcp/TcpTransportChannel.java v 1.23

src/java/org/codehaus/activemq/transport/udp/UdpTransportChannel.java v 1.16

src/java/org/codehaus/activemq/transport/vm/VmTransportChannel.java v 1.11

src/test/org/codehaus/activemq/broker/MockBrokerClient.java v 1.13

src/test/org/codehaus/activemq/capacity/BasicCapacityMonitorTest.java v 1.1

src/test/org/codehaus/activemq/message/util/MemoryBoundedQueueTest.java v 1.1

src/test/org/codehaus/activemq/transport/reliable/ReliableTransportChannelFactoryTest.java v 1.1

Added support for flow control and reliability
2004-07-22 13:51:17stewie

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.4

Added support for flow control and reliability
2004-07-22 13:50:07stewie

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.40

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.7

Added support for flow control and reliability
2004-07-22 08:54:54James Strachan

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.7

updated timer to fix a failing test
2004-07-22 08:25:47James Strachan

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.6

made close more explicit, nulling resources so we can tell if things are tried to be stopped twice. also temporarily disabled the use of persistence until I fix all the unit test cases
2004-07-22 07:37:17James Strachan

src/test/org/codehaus/activemq/service/TopicBrokerTest.java v 1.2

More fixes of old tests which don't work so well now that persistence is enabled by default
2004-07-22 07:24:27James Strachan

src/test/org/codehaus/activemq/JmsTopicSendReceiveTest.java v 1.14

src/test/org/codehaus/activemq/TestSupport.java v 1.5

src/test/org/codehaus/activemq/service/QueueBrokerTest.java v 1.2

More fixes of old tests which don't work so well now that persistence is enabled by default
2004-07-22 07:21:19James Strachan

src/test/org/codehaus/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java v 1.9

More fixes of old tests which don't work so well now that persistence is enabled by default
2004-07-22 06:54:48James Strachan

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.5

src/test/org/codehaus/activemq/service/SimpleTopicBrokerTest.java v 1.2

Added better loggging when creating a data directory and minor fix to a failing test
2004-07-21 21:45:45James Strachan

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.4

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.8

src/test/org/codehaus/activemq/JmsDurableTopicSendReceiveTest.java v 1.1

src/test/org/codehaus/activemq/JmsSendReceiveTestSupport.java v 1.6

src/test/org/codehaus/activemq/JmsTopicSendReceiveTest.java v 1.13

src/test/org/codehaus/activemq/JmsTopicSendReceiveWithTwoConnectionsTest.java v 1.8

Enabled JDBM by default for durable persistence
2004-07-21 19:46:09James Strachan

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.3

added helper methods for easier auto-configuration and made broker easier to configure via Spring
2004-07-21 19:15:19James Strachan

src/java/org/codehaus/activemq/DuplicateDurableSubscriptionException.java v 1.1

src/java/org/codehaus/activemq/broker/impl/BrokerClientImpl.java v 1.3

src/java/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.2

src/java/org/codehaus/activemq/service/Subscription.java v 1.10

src/java/org/codehaus/activemq/service/SubscriptionContainer.java v 1.4

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.7

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscriptionContainer.java v 1.4

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.6

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.7

Added extra check that we don't have a current subscription already existing which has the same clientID and subscriberName - if so we throw an excpetion
2004-07-21 18:08:36James Strachan

src/java/org/codehaus/activemq/message/ActiveMQMessage.java v 1.17

src/java/org/codehaus/activemq/service/MessageStore.java v 1.8

src/java/org/codehaus/activemq/service/MessageStoreTestSupport.java v 1.1

src/java/org/codehaus/activemq/service/QueueMessageContainer.java v 1.5

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.10

src/test/org/codehaus/activemq/service/QueueMessageStoreTestSupport.java v 1.1

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.6

Added test cases & implementation of durable queue based recovery with implementations for BDB and JDBM
2004-07-21 16:17:04James Strachan

src/java/org/codehaus/activemq/service/TopicMessageStore.java v 1.5

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainer.java v 1.10

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.5

fixed durable topic recovery so that failure for a subscription which is initiated but never acknowledges any messages works correctly - next recovery point will be started from the correct point. i.e. we now store a checkpoint on start of a durable topic subscription. (If we don't store a checkpoint it means start from the beginning of the durable message store)
2004-07-21 15:21:25James Strachan

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.4

topic durable subscription recovery tested & working for BDB JE
2004-07-21 14:44:52James Strachan

src/java/org/codehaus/activemq/service/MessageIdentity.java v 1.5

src/java/org/codehaus/activemq/service/MessageStore.java v 1.7

src/java/org/codehaus/activemq/service/PersistenceAdapter.java v 1.3

src/java/org/codehaus/activemq/service/Subscription.java v 1.9

src/java/org/codehaus/activemq/service/TopicMessageContainer.java v 1.5

src/java/org/codehaus/activemq/service/TopicMessageStore.java v 1.4

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.9

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainer.java v 1.9

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.6

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscription.java v 1.3

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.7

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.5

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.13

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.3

topic durable subscription recovery tested & working for JDBM
2004-07-21 11:46:31James Strachan

src/java/org/codehaus/activemq/service/Subscription.java v 1.8

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.6

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.4

more refactorings to ensure we pass around MessageIdentity rather than String messageID
2004-07-21 10:42:13James Strachan

src/java/org/codehaus/activemq/ActiveMQConnection.java v 1.39

src/java/org/codehaus/activemq/ActiveMQSession.java v 1.32

src/java/org/codehaus/activemq/ActiveMQTopicSubscriber.java v 1.6

src/java/org/codehaus/activemq/message/ActiveMQDestination.java v 1.13

src/java/org/codehaus/activemq/message/ActiveMQMessage.java v 1.16

src/java/org/codehaus/activemq/service/MessageContainer.java v 1.9

src/java/org/codehaus/activemq/service/MessageIdentity.java v 1.4

src/java/org/codehaus/activemq/service/QueueMessageContainer.java v 1.4

src/java/org/codehaus/activemq/service/Subscription.java v 1.7

src/java/org/codehaus/activemq/service/TopicMessageContainer.java v 1.4

src/java/org/codehaus/activemq/service/TopicMessageStore.java v 1.3

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.8

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainer.java v 1.8

src/java/org/codehaus/activemq/service/impl/DurableTopicSubscription.java v 1.2

src/java/org/codehaus/activemq/service/impl/MessagePointer.java v 1.2

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.5

src/java/org/codehaus/activemq/service/impl/SubscriptionImpl.java v 1.3

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.12

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.2

refactor so that the core MessageContainer and MessageStore APIs take a MessageIdentity rather than a String messageID. This allows us to lazily associate a message identity with a unique ordered sequenceNumber and use that in the various persistent methods to avoid unnecessary lookups
2004-07-21 06:18:48James Strachan

project.xml v 1.94

src/java/org/codehaus/activemq/filter/DestinationFilter.java v 1.2

src/java/org/codehaus/activemq/message/ActiveMQDestination.java v 1.12

src/java/org/codehaus/activemq/message/ActiveMQMessage.java v 1.15

src/java/org/codehaus/activemq/service/MessageContainer.java v 1.8

src/java/org/codehaus/activemq/service/MessageIdentity.java v 1.3

src/java/org/codehaus/activemq/service/MessageStore.java v 1.6

src/java/org/codehaus/activemq/service/impl/DefaultBroker.java v 1.2

src/java/org/codehaus/activemq/service/impl/DurableQueueMessageContainer.java v 1.7

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainer.java v 1.7

src/java/org/codehaus/activemq/service/impl/DurableTopicMessageContainerManager.java v 1.5

src/java/org/codehaus/activemq/service/impl/InitialImageMessageContainerManager.java v 1.1

src/java/org/codehaus/activemq/service/impl/MessageEntry.java v 1.2

src/java/org/codehaus/activemq/service/impl/ProxyMessageContainerManager.java v 1.1

src/java/org/codehaus/activemq/service/impl/QueueMessageContainerManager.java v 1.4

src/java/org/codehaus/activemq/service/impl/TransientTopicMessageContainerManager.java v 1.2

src/java/org/codehaus/activemq/util/LRUCache.java v 1.1

src/test/org/codehaus/activemq/service/MessageContainerTestSupport.java v 1.11

src/test/org/codehaus/activemq/service/TopicMessageStoreTestSupport.java v 1.1

Refactorings to allow more efficient persistent stores. Close to full optimal implementation for BDB and JDBM Added early cut of an initial image cache container