The project Apache ActiveMQ - trunk branch has the following 345 changes by 7 authors:
*Rob Davies* made the following changes at 08:16 AM, 02 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1533
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (608034)
*Rob Davies* made the following changes at 07:52 PM, 28 December 2007
Comment:
Tweaking for Queue performance and concurrency
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TransactionTest.java (607317)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (607317)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java (607317)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (607317)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java (607317)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/QueueRepeaterTest.java (607317)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (607317)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TestSupport.java (607317)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerRestartTestSupport.java (607317)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (607317)
*Rob Davies* made the following changes at 08:11 AM, 28 December 2007
Comment:
This test could get stuck - now only wait 2 seconds for a message
and use Memory Message Store
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TransactionTest.java (607186)
*Hiram Chirino* made the following changes at 02:36 PM, 27 December 2007
Comment:
Adding missing resource file.
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/transport/stomp (607074)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/transport (607074)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/transport/stomp/stomp-auth-broker.xml (607074)
*Rob Davies* made the following changes at 11:06 AM, 27 December 2007
Comment:
Reduce contention around Queues
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/AMQStoreDurableTopicTest.java (607038)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (607038)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (607038)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java (607038)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (607038)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java (607038)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicNetworkTest.java (607038)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/RoundRobinDispatchPolicy.java (607038)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (607038)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/ReconnectTest.java (607038)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (607038)
*Rob Davies* made the following changes at 11:03 AM, 27 December 2007
Comment:
fix for http://issues.apache.org/activemq/browse/AMQ-1157
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java (607037)
*Rob Davies* made the following changes at 09:42 AM, 24 December 2007
Comment:
multiple paths try to re-start the broker with vm:// trapnsport -
changed URI to tcp://
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ReliableReconnectTest.java (606682)
*Rob Davies* made the following changes at 05:56 PM, 21 December 2007
Comment:
don't wait for ever for worker to stop
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/failover/ReconnectTest.java (606260)
*Rob Davies* made the following changes at 04:45 PM, 21 December 2007
Comment:
Only wait 1 second for connections to stop. When killing a stale
connection - if stop doesn't complete - it hangs the broker.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (606241)
*Rob Davies* made the following changes at 08:42 PM, 20 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1528
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (606022)
*Hiram Chirino* made the following changes at 04:23 PM, 20 December 2007
Comment:
Updated version number now that 5.0.0 is out the door
> /activemq/trunk/activemq-optional/pom.xml (605972)
> /activemq/trunk/activemq-tooling/maven-activemq-perf-plugin/pom.xml (605972)
> /activemq/trunk/activemq-jaas/pom.xml (605972)
> /activemq/trunk/activemq-web/pom.xml (605972)
> /activemq/trunk/activemq-fileserver/pom.xml (605972)
> /activemq/trunk/activemq-tooling/maven-activemq-memtest-plugin/pom.xml (605972)
> /activemq/trunk/activemq-web-demo/pom.xml (605972)
> /activemq/trunk/activemq-all/pom.xml (605972)
> /activemq/trunk/activemq-test-atomikos/pom.xml (605972)
> /activemq/trunk/activemq-systest/pom.xml (605972)
> /activemq/trunk/activemq-xmpp/pom.xml (605972)
> /activemq/trunk/activemq-repository-builder/pom.xml (605972)
> /activemq/trunk/activemq-openwire-generator/pom.xml (605972)
> /activemq/trunk/pom.xml (605972)
> /activemq/trunk/activemq-rar/pom.xml (605972)
> /activemq/trunk/activemq-tooling/pom.xml (605972)
> /activemq/trunk/activemq-console/pom.xml (605972)
> /activemq/trunk/activemq-jpa-store/pom.xml (605972)
> /activemq/trunk/activemq-web-console/pom.xml (605972)
> /activemq/trunk/activemq-book/pom.xml (605972)
> /activemq/trunk/activemq-tooling/maven-activemq-plugin/pom.xml (605972)
> /activemq/trunk/activemq-perftest/pom.xml (605972)
> /activemq/trunk/assembly/pom.xml (605972)
> /activemq/trunk/activemq-core/pom.xml (605972)
> /activemq/trunk/activemq-ra/pom.xml (605972)
*Hiram Chirino* made the following changes at 02:37 PM, 20 December 2007
Comment:
Applied Dejan's patch on AMQ-1272 with some small tweaks.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompConnection.java (605944)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java (605944)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java (605944)
*Rob Davies* made the following changes at 02:35 PM, 20 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1524
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (605943)
*Rob Davies* made the following changes at 02:29 PM, 20 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1528
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (605940)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java (605940)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java (605940)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (605940)
*Rob Davies* made the following changes at 09:09 PM, 19 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1525
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java (605698)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/SchedulerTimerTask.java (605698)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (605698)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java (605698)
*Rob Davies* made the following changes at 07:50 PM, 19 December 2007
Comment:
close socket in a separate thread and only await stopLatch
for 2 seconds - as it close could be called by InactivityMonitor
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java (605671)
*Rob Davies* made the following changes at 11:49 AM, 19 December 2007
Comment:
ConnectionClosed exceptions being thrown in a regular connection close
removed the isClosing() check before sending async
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (605518)
*Rob Davies* made the following changes at 08:40 PM, 16 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1521
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java (604700)
*Rob Davies* made the following changes at 08:16 PM, 16 December 2007
Comment:
update performance tests
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/AMQStoreDurableTopicTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNetworkTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/KahaDurableTopicTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleDurableTopicNetworkTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/JournalKahaDurableTopicTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/QueueConnectionMemoryTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SlowConsumerTopicTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/KahaQueueTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/AMQStoreQueueTest.java (604691)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/JournalKahaQueueTest.java (604691)
*Rob Davies* made the following changes at 08:14 PM, 16 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1518
take minimum threads to task factory to 0
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/TaskRunnerFactory.java (604689)
*Rob Davies* made the following changes at 04:52 PM, 13 December 2007
Comment:
try and ensure that the brokers shutdown cleanly for the
ReliableReconnectTest - as it can hang
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (603952)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (603952)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/ReliableReconnectTest.java (603952)
*Rob Davies* made the following changes at 02:45 PM, 13 December 2007
Comment:
changed unlock() method to use remove() instead of clearProperty
as this doesn't work on some platforms
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (603927)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (603927)
*Rob Davies* made the following changes at 11:02 AM, 13 December 2007
Comment:
Add warning message if not enough space to complete a transaction
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (603884)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transaction/Transaction.java (603884)
*Rob Davies* made the following changes at 10:56 AM, 13 December 2007
Comment:
If can't recover message id from the store - change error message
to debug. The problem occurs because the message has already been
dispatched
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java (603881)
*Rob Davies* made the following changes at 10:41 AM, 13 December 2007
Comment:
crap - left a Thread.dumpStack() method in the class - removing
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java (603873)
*Rob Davies* made the following changes at 09:57 AM, 13 December 2007
Comment:
crap - left a Thread.dumpStack() method in the class - removing
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (603869)
*Rob Davies* made the following changes at 09:19 AM, 13 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1507
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (603863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (603863)
*Rob Davies* made the following changes at 11:10 PM, 12 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1507
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveTest.java (603772)
*Rob Davies* made the following changes at 10:53 PM, 12 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1507
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (603762)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (603762)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java (603762)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java (603762)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (603762)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveTest.java (603762)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveTestUsingSharedFileTest.java (603762)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BitArrayBin.java (603762)
*Rob Davies* made the following changes at 08:19 PM, 11 December 2007
Comment:
Added more synchronization
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicSub.java (603348)
*Hiram Chirino* made the following changes at 09:45 PM, 08 December 2007
Comment:
Applied patch in AMQ-1515 Thx David.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ClassLoading.java (602565)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v2/BaseDataStreamMarshaller.java (602565)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ClassLoadingAwareObjectInputStream.java (602565)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v3/BaseDataStreamMarshaller.java (602565)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/v1/BaseDataStreamMarshaller.java (602565)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java (602565)
*Hiram Chirino* made the following changes at 09:31 PM, 08 December 2007
Comment:
Added a little more debug logging to the InactivityMonitor because I suspect that
the schedular might not be triggering the read and write checks at the right time.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (602553)
*Hiram Chirino* made the following changes at 06:56 PM, 08 December 2007
Comment:
If you have a multi-threaded client which share 1 connection to the broker it is possible you may have seen errors like:
2007-12-05 14:14:52,606 [VMTransport] ERROR - org.apache.activemq.broker.TransportConnection.Service - Async error occurred: java.lang.IllegalStateException: Cannot lookup a connection that had not been registered: ID:bubba-38184-1196882086290-2:1
java.lang.IllegalStateException: Cannot lookup a connection that had not been registered: ID:bubba-38184-1196882086290-2:1
at org.apache.activemq.broker.SingleTransportConnectionStateRegister.lookupConnectionState(SingleTransportConnectionStateRegister.java:113)
at org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1313)
at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:538)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202)
at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118)
at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
at java.lang.Thread.run(Thread.java:619)
root cause is that the client side has multiple threads calling close() on consumer/session and the connection objects. If the timing of those concurrent calls was just right, it is possible for the client to send the connection close message followed by a session or consumer close message which is invalid and would result in IllegalStateException reported by the broker.
- Simplified the ActiveMQConnection and TransportConnection shutdown so that this does does not happen.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (602529)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (602529)
*Rob Davies* made the following changes at 10:03 AM, 08 December 2007
Comment:
Fix for excessive memory usage for durable consumers -
see https://issues.apache.org/activemq/browse/AMQ-1490
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (602440)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java (602440)
*Rob Davies* made the following changes at 10:47 PM, 07 December 2007
Comment:
Added synchronization to prevent concurrent modification
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicSub.java (602260)
*Rob Davies* made the following changes at 05:21 PM, 04 December 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1512
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (601011)
*Rob Davies* made the following changes at 11:27 AM, 04 December 2007
Comment:
Changes to address memory usage for large transactions for:
https://issues.apache.org/activemq/browse/AMQ-1490
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IOHelper.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicMessageStore.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubContainer.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java (600891)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (600891)
> /activemq/trunk/activemq-core/pom.xml (600891)
*Rob Davies* made the following changes at 08:33 PM, 03 December 2007
Comment:
Using wrong class to initialize the log
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (600671)
*Hiram Chirino* made the following changes at 10:39 PM, 30 November 2007
Comment:
handle the inactivity actions in an async thread so that the schedular thread does not get blocked.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (599993)
*Hiram Chirino* made the following changes at 02:42 PM, 30 November 2007
Comment:
Allow a blocked thread to unwind if it's connection is getting terminated.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (599835)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (599835)
*Hiram Chirino* made the following changes at 03:51 PM, 29 November 2007
Comment:
Glen Mazza pointed out a little typo
> /activemq/trunk/activemq-web-demo/src/main/webapp/index.html (599493)
*Rob Davies* made the following changes at 03:03 PM, 29 November 2007
Comment:
updated so that we can use delete the db on start-up
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java (599470)
*Rob Davies* made the following changes at 08:19 PM, 28 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1490
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BitArrayBin.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/MemoryUsage.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageAudit.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (599129)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (599129)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubContainer.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (599129)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (599129)
*Rob Davies* made the following changes at 08:02 PM, 28 November 2007
Comment:
removed System.out logging
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java (599122)
*Guillaume Nodet* made the following changes at 10:26 AM, 28 November 2007
Comment:
Camel should be optional
> /activemq/trunk/activemq-core/pom.xml (598942)
*Rob Davies* made the following changes at 04:15 PM, 26 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1502
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedListTest.java (598330)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/BaseContainerImpl.java (598330)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java (598330)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexLinkedList.java (598330)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedListTest.java (598330)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/ListContainerImpl.java (598330)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedList.java (598330)
*Rob Davies* made the following changes at 07:51 AM, 23 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1491
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java (597582)
*Rob Davies* made the following changes at 07:40 AM, 23 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1500
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (597581)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (597581)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java (597581)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (597581)
*Hiram Chirino* made the following changes at 03:11 PM, 12 November 2007
Comment:
Adding missing headers
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/security/AMQauth.ldif (594172)
*Hiram Chirino* made the following changes at 03:09 PM, 12 November 2007
Comment:
Adding missing headers
> /activemq/trunk/activemq-fileserver/src/main/webapp/WEB-INF/web.xml (594170)
> /activemq/trunk/activemq-fileserver/src/main/webapp/index.html (594170)
> /activemq/trunk/activemq-tooling/etc/css/stylesheet.css (594170)
> /activemq/trunk/etc/css/stylesheet.css (594170)
> /activemq/trunk/assembly/src/release/webapps/index.html (594170)
*Hiram Chirino* made the following changes at 04:30 PM, 09 November 2007
Comment:
Scale back this test a little bit. It was storing 1.6 GIG is message contents. Which took a long time to store and also
will fail on machines that don't have the much free space. If we want to run BIG tests like that they should go into a
system testing module. Scaled it back so that only 160 Megs of data are generated by the test
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java (593585)
*Hiram Chirino* made the following changes at 03:39 PM, 08 November 2007
Comment:
The VMTransport now let's it's peer know when it's being stopped so that the Peer can give its' transport listener a peer disconnected exception. Otherwise a VM transport client could disconnect without the server side knowing it disconnected and the server side would not terminate it's side of the connection. This could be seen as a memory leak on when the static network config is setup and one of the static brokers is not up.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java (593204)
*Hiram Chirino* made the following changes at 05:06 PM, 07 November 2007
Comment:
Update YourKit profiling options since we now require java 1.5
> /activemq/trunk/assembly/src/release/bin/activemq.bat (592818)
> /activemq/trunk/assembly/src/release/bin/activemq (592818)
*Hiram Chirino* made the following changes at 07:44 PM, 06 November 2007
Comment:
Added better temp destination support. We now properly create temp destinations that the client can subscribe to
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/LegacyFrameTranslator.java (592531)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/FrameTranslator.java (592531)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java (592531)
*Hiram Chirino* made the following changes at 06:47 PM, 05 November 2007
Comment:
- memory leak fix: TransportConnection would leak memory if an error occured while start()ing the connection. Most visible when you create a network connector pointing at a remote broker that was down since this loops through creating TransportConnectors every few seconds.
- Deadlock fix VMTransport could dead lock if during start() an error occured and stop was recusively called.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (592114)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/Valve.java (592114)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java (592114)
*Hiram Chirino* made the following changes at 05:07 PM, 05 November 2007
Comment:
- Reduced verbosity of logging in TransportConnector so that exceptions should only be in DEBUG messages.
- Added more logging to SimpleDiscoveryAgent so that we can see what it's doing in regards to reconnect handling and
enabled exponential backoff by default.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java (592090)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java (592090)
*Hiram Chirino* made the following changes at 04:13 PM, 05 November 2007
Comment:
failover is no longer a vaild option on networkConnector
> /activemq/trunk/assembly/src/release/conf/activemq.xml (592061)
*Hiram Chirino* made the following changes at 04:06 PM, 05 November 2007
Comment:
The conf directory should be relative to the ACTIVEMQ_BASE
> /activemq/trunk/assembly/src/release/bin/activemq.bat (592057)
> /activemq/trunk/assembly/src/release/bin/activemq (592057)
*Rob Davies* made the following changes at 08:09 PM, 02 November 2007
Comment:
Further enhancement to https://issues.apache.org/activemq/browse/AMQ-1246
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (591442)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/hash/HashTest.java (591442)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java (591442)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (591442)
*Rob Davies* made the following changes at 10:42 PM, 01 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1246
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java (591160)
*Rob Davies* made the following changes at 09:49 PM, 01 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1486
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (591148)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java (591148)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (591148)
*Rob Davies* made the following changes at 09:23 PM, 01 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1485
Fix npe for above
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (591145)
*Rob Davies* made the following changes at 08:26 PM, 01 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1485
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (591142)
*Rob Davies* made the following changes at 06:37 PM, 01 November 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1485
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (591113)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IOHelper.java (591113)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (591113)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (591113)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java (591113)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java (591113)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java (591113)
*Rob Davies* made the following changes at 11:09 AM, 31 October 2007
Comment:
updated properties
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (590623)
*Rob Davies* made the following changes at 10:54 AM, 28 October 2007
Comment:
tidy up comments
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (589330)
*Rob Davies* made the following changes at 09:39 AM, 28 October 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1479
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/AMQStoreDurableTopicTest.java (589314)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (589314)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (589314)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (589314)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java (589314)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LRUSet.java (589314)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/AMQStoreQueueTest.java (589314)
*Rob Davies* made the following changes at 05:14 AM, 27 October 2007
Comment:
Test case for: https://issues.apache.org/activemq/browse/AMQ-1479
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java (589048)
*Hiram Chirino* made the following changes at 09:20 PM, 26 October 2007
Comment:
The caching of the prepared statement for updating the last ack was wrong.
Reported at http://www.nabble.com/Is-this-a-bug-in-DefaultJDBCAdapter.java--tf1890445s2354.html#a5170127
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/adapter/DefaultJDBCAdapter.java (588767)
*Hiram Chirino* made the following changes at 07:16 PM, 26 October 2007
Comment:
fix bad cast
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (588731)
*Hiram Chirino* made the following changes at 07:00 PM, 26 October 2007
Comment:
Avoid deleting datafiles that are in-use.. timing issue was making this possible
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (588725)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (588725)
*Hiram Chirino* made the following changes at 06:32 PM, 26 October 2007
Comment:
MarshallingSupport.unmarshalPrimitive is throwing "Unknown primitive type: 0" when nested map contains a null
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/MarshallingSupport.java (588718)
*Hiram Chirino* made the following changes at 04:43 PM, 25 October 2007
Comment:
Removed synchronizations on all the processXXX() methods to avoid getting into situations where deadlocks occur.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (588260)
*Hiram Chirino* made the following changes at 05:53 PM, 24 October 2007
Comment:
Cleanup the leaky abstraction of the DiscoveryAgent. see:
https://issues.apache.org/activemq/browse/AMQ-1477
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/rendezvous/RendezvousDiscoveryAgent.java (587927)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DiscoveryNetworkConnector.java (587927)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/multicast/MulticastDiscoveryAgent.java (587927)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgentFactory.java (587927)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java (587927)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/DiscoveryAgent.java (587927)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgent.java (587927)
*Hiram Chirino* made the following changes at 08:11 PM, 23 October 2007
Comment:
allow any setter to be called
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IntrospectionSupport.java (587618)
*Hiram Chirino* made the following changes at 02:58 PM, 23 October 2007
Comment:
https://issues.apache.org/activemq/browse/AMQ-1268
Test case regression was fixed.. enabling test again
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java (587509)
*Hiram Chirino* made the following changes at 02:52 PM, 23 October 2007
Comment:
Applied patch: https://issues.apache.org/activemq/browse/AMQ-1238
- Allows java service wrapper start script to work on Debian sarge
> /activemq/trunk/assembly/src/release/bin/linux/activemq (587507)
*Hiram Chirino* made the following changes at 02:36 PM, 23 October 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-796
- The threads associated with the session are now setup to be non-daemon so that if you
setup a MessageListener and let the main thread exit, your program will not terminate
if there are no active transport threads which is the case when the failover transport
is in the middle of reconnecting to a broker.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (587504)
*Rob Davies* made the following changes at 06:38 AM, 23 October 2007
Comment:
synchronize doMessageSend() to ensure messages are stored and dispatched
in the right order
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (587396)
*Hiram Chirino* made the following changes at 08:37 PM, 22 October 2007
Comment:
Test case and Fix for https://issues.apache.org/activemq/browse/AMQ-777
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/discovery/DiscoveryTransportNoBrokerTest.java (587216)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (587216)
*Hiram Chirino* made the following changes at 08:01 PM, 22 October 2007
Comment:
Avoid deadlock described at: https://issues.apache.org/activemq/browse/AMQ-1468
Synchronization not really required once the transport errors out..
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (587198)
*Hiram Chirino* made the following changes at 07:39 PM, 22 October 2007
Comment:
Fixed the test cases in FanoutTransportBrokerTest also added a fanOutQueues property to enabled fanning out on
Queues. See issue: https://issues.apache.org/activemq/browse/AMQ-1464
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java (587188)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/fanout/FanoutTransportBrokerTest.java (587188)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java (587188)
*Rob Davies* made the following changes at 02:45 PM, 22 October 2007
Comment:
check for message order
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java (587091)
*Rob Davies* made the following changes at 11:10 AM, 22 October 2007
Comment:
remove System messages
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (587051)
*Rob Davies* made the following changes at 09:38 AM, 22 October 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1449
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (587033)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (587033)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (587033)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java (587033)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (587033)
*Rob Davies* made the following changes at 08:07 PM, 19 October 2007
Comment:
fix for https://issues.apache.org/activemq/browse/AMQ-1467
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java (586581)
*Rob Davies* made the following changes at 08:01 PM, 19 October 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1452 and
https://issues.apache.org/activemq/browse/AMQ-729
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageAudit.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (586580)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ConnectionAudit.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BitArrayBin.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (586580)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java (586580)
*Hiram Chirino* made the following changes at 02:56 PM, 19 October 2007
Comment:
Reduced the amount of time that the synchronizations are held to avoid deadlocks
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (586460)
*James Strachan* made the following changes at 01:32 PM, 19 October 2007
Comment:
upgraded to 1.2.0 release of camel
> /activemq/trunk/pom.xml (586402)
*jlim* made the following changes at 04:54 AM, 19 October 2007
Comment:
applied patch for AMQ-1440 and AMQ-1439
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java (586251)
*Hiram Chirino* made the following changes at 01:00 AM, 19 October 2007
Comment:
The VM transport could deadlock between the iterate() method and the oneway() method when the async message buffer used by the transport fills up. Change the synchronization logic to make use the a Valve to avoid needing to lock mutexes for so long.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java (586185)
*Rob Davies* made the following changes at 05:22 PM, 18 October 2007
Comment:
Check for duplicates
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java (586025)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java (586025)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleTopicTest.java (586025)
*Rob Davies* made the following changes at 03:08 PM, 18 October 2007
Comment:
fix for https://issues.apache.org/activemq/browse/AMQ-1467
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (585967)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedListTest.java (585967)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (585967)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ProducerBrokerExchange.java (585967)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedList.java (585967)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java (585967)
*jlim* made the following changes at 10:09 AM, 18 October 2007
Comment:
updates for https://issues.apache.org/activemq/browse/AMQ-1358
> /activemq/trunk/activemq-web-console/src/main/webapp/WEB-INF/tags/jms/formatTimestamp.tag (585905)
> /activemq/trunk/activemq-web-console/src/main/webapp/browse.jsp (585905)
*Rob Davies* made the following changes at 05:10 AM, 18 October 2007
Comment:
updated for https://issues.apache.org/activemq/browse/AMQ-1251
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (585853)
*Rob Davies* made the following changes at 04:53 AM, 18 October 2007
Comment:
Test case for https://issues.apache.org/activemq/browse/AMQ-1202
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkConnectionsCleanedupTest.java (585843)
> /activemq/trunk/activemq-core/pom.xml (585843)
*James Strachan* made the following changes at 09:37 AM, 27 September 2007
Comment:
updated the stax version
> /activemq/trunk/pom.xml (579943)
*James Strachan* made the following changes at 09:26 AM, 27 September 2007
Comment:
added patch for https://issues.apache.org/activemq/browse/AMQ-1435 to handle Mirrored Queues (so that folks can consume on a topic what messages are sent to a queue)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (579941)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java (579941)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java (579941)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationInterceptor.java (579941)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopicInterceptor.java (579941)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java (579941)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueTest.java (579941)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java (579941)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueUsingVirtualTopicQueueTest.java (579941)
*James Strachan* made the following changes at 01:30 PM, 26 September 2007
Comment:
minor change to make tests more exclusive to avoid 'em hitting each other
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java (579639)
*James Strachan* made the following changes at 09:08 AM, 26 September 2007
Comment:
added patch for AMQ-1434 to allow transport listeners to be used with a connection factory for easy integration with Spring JmsTemplate etc
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java (579498)
*Rob Davies* made the following changes at 06:00 PM, 24 September 2007
Comment:
fix reference counting
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (578877)
*Hiram Chirino* made the following changes at 08:11 PM, 20 September 2007
Comment:
Better broker shutdown handling and also better test support.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java (577882)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (577882)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/JmsSendReceiveTestSupport.java (577882)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/StubConnection.java (577882)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java (577882)
*Hiram Chirino* made the following changes at 08:09 PM, 20 September 2007
Comment:
Removing invalid testcase. This test was setting up 2 consumers and storing the message sequences in a single list for both. Further more it was checking that those messages were delivered in order. It is not possible garantee order between 2 consumers.. therefore this test is invalid.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueSendReceiveMultipleConsumersTest.java (577881)
*Hiram Chirino* made the following changes at 07:57 PM, 20 September 2007
Comment:
Fix for broken test
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/ActiveMQConfigureTest.java (577878)
*Hiram Chirino* made the following changes at 07:49 PM, 20 September 2007
Comment:
Fix broke test.. A transaction manager is now required when transacted endpoints are configured.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/ActiveMQRouteTest.java (577869)
*Guillaume Nodet* made the following changes at 03:16 PM, 20 September 2007
Comment:
AMQ-1429: Package ActiveMQ as OSGi bundles instead of plain jars
> /activemq/trunk/activemq-jaas/pom.xml (577760)
> /activemq/trunk/pom.xml (577760)
> /activemq/trunk/activemq-core/pom.xml (577760)
*Hiram Chirino* made the following changes at 03:13 PM, 20 September 2007
Comment:
ActiveMQ is out of the incubator.. no need for DISCLAIMER.txt anymore
> /activemq/trunk/activemq-core/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-web/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-openwire-generator/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-web-console/src/main/webapp/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-ra/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-perftest/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-soaktest/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-jaas/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-core/src/test/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-rar/src/main/rar/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-optional/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-jpa-store/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-web-demo/src/main/webapp/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-xmpp/src/main/resources/META-INF/DISCLAIMER.txt (577759)
> /activemq/trunk/activemq-systest/src/main/resources/META-INF/DISCLAIMER.txt (577759)
*Rob Davies* made the following changes at 02:49 PM, 20 September 2007
Comment:
make the locking more coarse grained
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (577746)
*Rob Davies* made the following changes at 12:09 PM, 20 September 2007
Comment:
Don't use System.out
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java (577683)
*Rob Davies* made the following changes at 06:06 PM, 17 September 2007
Comment:
remove unused imports
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java (576527)
*Rob Davies* made the following changes at 06:38 PM, 11 September 2007
Comment:
use default amq persistence
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/InactiveDurableTopicTest.java (574646)
*James Strachan* made the following changes at 06:47 AM, 11 September 2007
Comment:
use the same ConnectionFactory so that transactional consume + send can use the same session
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQConfiguration.java (574465)
*James Strachan* made the following changes at 06:20 AM, 11 September 2007
Comment:
added better debug logging
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java (574460)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java (574460)
*Hiram Chirino* made the following changes at 09:44 PM, 10 September 2007
Comment:
Make activemq-web compile.. needed an explict dependency on spring-webmvc
> /activemq/trunk/activemq-web/pom.xml (574368)
*Hiram Chirino* made the following changes at 07:41 PM, 10 September 2007
Comment:
Update to the latest version of xbean
> /activemq/trunk/pom.xml (574327)
> /activemq/trunk/activemq-core/pom.xml (574327)
*Hiram Chirino* made the following changes at 07:38 PM, 10 September 2007
Comment:
Updated to latest version of openjpa
> /activemq/trunk/pom.xml (574325)
*Hiram Chirino* made the following changes at 07:27 PM, 10 September 2007
Comment:
Switch to using a Timer to schedual tasks. Seems to have much more acurate time delays between executions.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java (574321)
*Hiram Chirino* made the following changes at 04:44 PM, 07 September 2007
Comment:
Moved the camel-activemq module into the activemq-core module to break the circular dependency between the activemq and camel projects.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/JournalEndpoint.java (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/package.html (573615)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/camel/component/activemq.journal (573615)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/ActiveMQReplyToHeaderUsingConverterTest.java (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQMessageConverter.java (573615)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/camel/TypeConverter (573615)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/JournalRouteTest.java (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component (573615)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/camel/component/activemq (573615)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/JournalConfigureTest.java (573615)
> /activemq/trunk/pom.xml (573615)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/ActiveMQRouteTest.java (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQConverter.java (573615)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/JournalRoutePerformance.java (573615)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/ActiveMQConfigureTest.java (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQConfiguration.java (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java (573615)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/camel/component (573615)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/camel (573615)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/ActiveMQJmsHeaderRouteTest.java (573615)
> /activemq/trunk/assembly/pom.xml (573615)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/JournalComponent.java (573615)
*Hiram Chirino* made the following changes at 11:19 PM, 06 September 2007
Comment:
Fix for the QueueWorkerPrefetchTest. The VMPendingMessageCursor.isEmpty() was returning true when it had an a message that had been marked dropped due to it being delivered by another subscription.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/MessageReference.java (573400)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java (573400)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java (573400)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (573400)
*Hiram Chirino* made the following changes at 11:14 PM, 06 September 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1382... if the broker.persistent==false then we should not create any files, not even for the Temp Store.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (573397)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java (573397)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (573397)
*Rob Davies* made the following changes at 07:29 AM, 24 August 2007
Comment:
ensure exception is logged if one is raised sending a message to a dead letter queue
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (569270)
*James Strachan* made the following changes at 05:42 PM, 23 August 2007
Comment:
moved the web helper classes to activemq-web so that they are reusable in other web apps easily
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacade.java (569067)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/SingletonBrokerFacade.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/SingletonBrokerFacade.java (569067)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/BrokerFacade.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/DestinationFacade.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/LocalBrokerFacade.java (569067)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/RemoteJMXBrokerFacade.java (569067)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/DestinationFacade.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacadeSupport.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/DurableSubscriberFacade.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/QueueBrowseQuery.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/RemoteJMXBrokerFacade.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/MessageQuery.java (569067)
> /activemq/trunk/activemq-web/src/main/java/org/apache/activemq/web/SessionPool.java (569067)
*jlim* made the following changes at 08:48 AM, 23 August 2007
Comment:
fix for https://issues.apache.org/activemq/browse/AMQ-1365
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/ConnectionKey.java (568869)
*James Strachan* made the following changes at 04:09 PM, 22 August 2007
Comment:
allow a MessageListener to be specified when creating a consumer; to avoid threading issues when creating lots of consumers after the connection has started
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueReceiver.java (568644)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQTopicSubscriber.java (568644)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java (568644)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java (568644)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQQueueBrowser.java (568644)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java (568644)
> /activemq/trunk/activemq-core/pom.xml (568644)
*James Strachan* made the following changes at 04:08 PM, 22 August 2007
Comment:
moved activeio into the optional section
> /activemq/trunk/assembly/src/main/descriptors/windows-bin.xml (568642)
> /activemq/trunk/assembly/src/main/descriptors/unix-bin.xml (568642)
*Hiram Chirino* made the following changes at 08:30 PM, 20 August 2007
Comment:
Made the SystemUsage and associated *Usage classes IOC friendly so that they can be configured
via xbean/spring. Fixed the ConfigTest test case.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/MemoryUsage.java (567796)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MessageExpirationTest.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/StoreUsage.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/TempUsage.java (567796)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/SystemUsage.java (567796)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQDeadlockTestW4Brokers.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (567796)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/AMQDeadlockTest3.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (567796)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/config/example.xml (567796)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/config/ConfigTest.java (567796)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java (567796)
*Rob Davies* made the following changes at 11:37 AM, 20 August 2007
Comment:
UpdateManager changed to account for Store and Temp data usage as well as memory usage
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTempQueueRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/LRUMap.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedQueueRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/TempUsage.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTempTopicRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/SystemUsage.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/Cache.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ProxyMessageStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/DefaultUsageCapacity.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheFilter.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/UsageManager.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreFactory.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/hash/HashTest.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/UsageCapacity.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCMessageStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/config/ConfigTest.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEvictionUsageListener.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/StoreUsage.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MessageExpirationTest.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQDeadlockTestW4Brokers.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTestSupport.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEvictor.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntryList.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/MapCache.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryPersistenceAdapter.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/SizeBasedMessageBufferTest.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/OrderBasedMemoryBufferTest.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/CacheEntry.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTopicRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/MemoryUsage.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/UsageManagerCacheFilter.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/tree/TreeTest.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalPersistenceAdapter.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/MessageStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/UsageListener.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ProxyTopicMessageStore.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/AMQDeadlockTest3.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/buffer/MemoryBufferTestSupport.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryMessageStore.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/proxy/ProxyTestSupport.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/UsageListener.java (567647)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/PersistenceAdapter.java (567647)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkTestSupport.java (567647)
*Rob Davies* made the following changes at 11:34 AM, 20 August 2007
Comment:
UpdateManager changed to account for Store and Temp data usage as well as memory usage
> /activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPAPersistenceAdapter.java (567646)
> /activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPAReferenceStore.java (567646)
> /activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPAMessageStore.java (567646)
*aco* made the following changes at 04:28 AM, 16 August 2007
Comment:
Commented out the threshold for the stdout logger, so it will use the global one.
> /activemq/trunk/assembly/src/release/conf/log4j.properties (566477)
*Hiram Chirino* made the following changes at 06:33 PM, 15 August 2007
Comment:
Improved the STOMP test case a little to verify that killed stomp clients redeliver un acked messages
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java (566277)
*Hiram Chirino* made the following changes at 03:46 PM, 15 August 2007
Comment:
Control file was not properly loading state when the the record length stored was not == to the max record length.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ControlFile.java (566202)
*James Strachan* made the following changes at 03:12 PM, 15 August 2007
Comment:
Attempt to fix AMQ-1363, to no avail
> /activemq/trunk/activemq-console/src/main/java/org/apache/activemq/console/Main.java (566177)
*James Strachan* made the following changes at 01:34 PM, 15 August 2007
Comment:
Removing unwanted test files from the test-jar
> /activemq/trunk/activemq-core/pom.xml (566121)
*Rob Davies* made the following changes at 01:54 PM, 30 August 2007
Comment:
test case for https://issues.apache.org/activemq/browse/AMQ-1251
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java (571150)
*Hiram Chirino* made the following changes at 09:49 PM, 30 August 2007
Comment:
Satitized the filenames that the KahaStore uses.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IOHelper.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/HexSupport.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/StoreFactory.java (571306)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java (571306)
*Rob Davies* made the following changes at 01:50 PM, 03 September 2007
Comment:
ensure the ConectionContext always has a broker set before sending message to DLQ
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (572300)
*adc* made the following changes at 05:57 AM, 04 September 2007
Comment:
ActiveIO removed its incubator label
> /activemq/trunk/pom.xml (572523)
*Rob Davies* made the following changes at 10:06 AM, 05 September 2007
Comment:
shorten the name of the container containing the SubscriberMessageList
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (572905)
*Rob Davies* made the following changes at 04:41 PM, 05 September 2007
Comment:
use potentially shorter container name for the topic subscriber references
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (572974)
*Rob Davies* made the following changes at 04:47 PM, 05 September 2007
Comment:
Ensure system safe names are used for container names
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (572975)
*Hiram Chirino* made the following changes at 06:18 PM, 05 September 2007
Comment:
Fixing compile issue cause by camel API change
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/CamelMessageProducer.java (573005)
*Hiram Chirino* made the following changes at 10:51 PM, 05 September 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1156
We now actually update the tcpNoDelay setting on the socket once the wireformat options are negociated. This allows
the client to control if his socket and the server's socket use the option. By default tcpNoDelay is enabled.
the client should use a URL like -Durl=tcp://localhost:61616?wireFormat.tcpNoDelayEnabled=false to disable tcpNoDelay on both the client and the server socket.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java (573080)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java (573080)
*Hiram Chirino* made the following changes at 08:25 PM, 06 September 2007
Comment:
Fixed synchronizations so that threads don't block each others processing as much and now the test works fine without hanging. see https://issues.apache.org/activemq/browse/AMQ-1251
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java (573342)
*Hiram Chirino* made the following changes at 11:05 PM, 06 September 2007
Comment:
if the container name has '/' in it then make sure we create the parent directories before we try to access the file.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (573392)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/IndexManager.java (573392)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java (573392)
*Hiram Chirino* made the following changes at 11:11 PM, 06 September 2007
Comment:
Fixed ContainerId so that it also uses the container name when it compares equality. Switch back to using a single index file
for the topic susbcriptions lists.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/ContainerId.java (573395)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (573395)
*Hiram Chirino* made the following changes at 02:35 PM, 27 September 2007
Comment:
Added the ASL to a bunch of property files.
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/discoveryagent/static (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/ibm_db2_jdbc_universal_driver_architecture (580013)
> /activemq/trunk/activemq-console/src/main/resources/META-INF/services/org/apache/activemq/broker/agent (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/spring.schemas (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/broker/xbean (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/udp (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/discoveryagent/rendezvous (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/stomp+ssl (580013)
> /activemq/trunk/activemq-web/src/main/resources/META-INF/services/org/apache/activemq/web/view/simple (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/postgresql_native_driver (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/sap_db (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/discovery (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/oracle_jdbc_driver (580013)
> /activemq/trunk/activemq-optional/src/main/resources/META-INF/services/org/apache/activemq/wireformat/xstream (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/spring.handlers (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/discoveryagent/multicast (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/wireformat/stomp (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/hsql_database_engine_driver (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/vm (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/jconnect__tm__for_jdbc__tm_ (580013)
> /activemq/trunk/activemq-web/src/main/resources/META-INF/services/org/apache/activemq/web/view/xml (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/microsoft_sql_server_2005_jdbc_driver (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/peer (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/apache_derby_embedded_jdbc_driver (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/wireformat/default (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/stomp (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/ssl (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/jtds_type_4_jdbc_driver_for_ms_sql_server_and_sybase (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/fanout (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/nio (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/sqlserver (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/i-net_sprinta_2000 (580013)
> /activemq/trunk/activemq-xmpp/src/main/resources/META-INF/services/org/apache/activemq/wireformat/xmpp (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/broker/broker (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/ibm_informix_jdbc_driver_for_ibm_informix_dynamic_server (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/broker/properties (580013)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/config/broker.properties (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/discoveryagent/simple (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/axion_jdbc_driver (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/store/jdbc/mysql-ab_jdbc_driver (580013)
> /activemq/trunk/activemq-xmpp/src/main/resources/META-INF/services/org/apache/activemq/transport/xmpp (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/multicast (580013)
> /activemq/trunk/activemq-web/src/main/resources/META-INF/services/org/apache/activemq/web/view/rss (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/mock (580013)
> /activemq/trunk/activemq-optional/src/main/resources/META-INF/services/org/apache/activemq/transport/http (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/failover (580013)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/tcp (580013)
> /activemq/trunk/activemq-optional/src/main/resources/META-INF/services/org/apache/activemq/transport/https (580013)
*Rob Davies* made the following changes at 10:46 AM, 28 September 2007
Comment:
Rolled back patches for https://issues.apache.org/activemq/browse/AMQ-1361 - as no licence headers where provided - we can't accept
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerControlMBean.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransportFactory.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/LogWriter.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LogWriterFinder.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerFactory.java (580273)
> /activemq/trunk/log_analyzer_tool (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerControl.java (580273)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/logwriters (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerViewMBean.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerView.java (580273)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/logwriters (580273)
*Hiram Chirino* made the following changes at 04:09 PM, 28 September 2007
Comment:
Make amq 5.x compatible again with 4.x clients
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (580382)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (580382)
*Hiram Chirino* made the following changes at 09:16 PM, 28 September 2007
Comment:
Fix failing test cases.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTestSupport.java (580475)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSMessageTest.java (580475)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransactionBroker.java (580475)
*Hiram Chirino* made the following changes at 11:00 PM, 28 September 2007
Comment:
Rolled back HttpTransportFactory to fix compile issue
> /activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpTransportFactory.java (580495)
*Hiram Chirino* made the following changes at 09:02 PM, 01 October 2007
Comment:
Fix for AMQ-1095:
- Added contributed test cases
- We now filter out non-matching messages as they are loaded into the TopicStorePrefetch
- Changed the TopicStorePrefetch and StoreDurableSubscriberCursor so that they don't depend
on the pending message counter since some stores cannot give an accurate count for it.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (581053)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/bugs/amq1095/activemq.xml (581053)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/bugs (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaMessageStore.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java (581053)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/bugs/amq1095 (581053)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/CursorSupport.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java (581053)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/amq1095 (581053)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (581053)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java (581053)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/amq1095/ActiveMQTestCase.java (581053)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/amq1095/MessageSelectorTest.java (581053)
*Rob Davies* made the following changes at 10:25 AM, 02 October 2007
Comment:
some unnecessary memory allocations removed
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/memory/LRUMap.java (581167)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ConnectionAudit.java (581167)
*James Strachan* made the following changes at 05:22 PM, 06 February 2008
Comment:
Use a larger send batch by default on the sample
> /activemq/trunk/assembly/src/release/example/build.xml (619078)
*Rob Davies* made the following changes at 09:51 AM, 07 February 2008
Comment:
Fix for:
https://issues.apache.org/activemq/browse/AMQ-1116
https://issues.apache.org/activemq/browse/AMQ-1575
https://issues.apache.org/activemq/browse/AMQ-1577
https://issues.apache.org/activemq/browse/AMQ-1581
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/pool/ConnectionPool.java (619336)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (619336)
*Rob Davies* made the following changes at 10:15 AM, 07 February 2008
Comment:
fix for https://issues.apache.org/activemq/browse/AMQ-1446
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryPersistenceAdapter.java (619347)
*Rob Davies* made the following changes at 12:55 PM, 07 February 2008
Comment:
cursor fixes
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQTextMessage.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java (619387)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (619387)
*Rob Davies* made the following changes at 12:56 PM, 07 February 2008
Comment:
slave deletes all messages on startup now
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/ft/slave.xml (619388)
*Rob Davies* made the following changes at 12:57 PM, 07 February 2008
Comment:
can't determine order messages will arrive in for separate queues
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java (619390)
*Rob Davies* made the following changes at 12:58 PM, 07 February 2008
Comment:
remove shutdown hook
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java (619391)
*Hiram Chirino* made the following changes at 05:13 PM, 07 February 2008
Comment:
Handle the OverlappingFileLockException that could occur.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ControlFile.java (619511)
*Rob Davies* made the following changes at 09:42 PM, 07 February 2008
Comment:
iterate() now returns false after every run to prevent spinning
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (619652)
*Rob Davies* made the following changes at 07:24 AM, 08 February 2008
Comment:
remove patch comment
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (619789)
*Rob Davies* made the following changes at 02:59 PM, 11 February 2008
Comment:
calculate message size even if the minimumMessageSize == 0
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (620500)
*Rob Davies* made the following changes at 10:04 AM, 12 February 2008
Comment:
Utility class for messages
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ActiveMQMessageUtils.java (620738)
*Rob Davies* made the following changes at 11:11 AM, 12 February 2008
Comment:
removed unused property
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BitArrayBin.java (620760)
*Rob Davies* made the following changes at 06:21 PM, 14 February 2008
Comment:
applied patch from https://issues.apache.org/activemq/browse/AMQ-1513
> /activemq/trunk/assembly/src/release/example/build.xml (627823)
*Rob Davies* made the following changes at 09:32 AM, 18 February 2008
Comment:
Fix some timing issues with test cases
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java (628663)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/policy/SimpleDispatchPolicyTest.java (628663)
*Rob Davies* made the following changes at 09:35 AM, 18 February 2008
Comment:
Fix some timing issues with test cases
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ExclusiveConsumerTest.java (628664)
*Rob Davies* made the following changes at 09:36 AM, 18 February 2008
Comment:
Added a TaksRunner that always executes iterate - even if its already running
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/DeterministicTaskRunner.java (628665)
*Rob Davies* made the following changes at 09:38 AM, 18 February 2008
Comment:
Change Queue dispatch model to reduce contention for lots of
consumers
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/DispatchSelector.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/NullMessageReference.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueDispatchSelector.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchSelector.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueMessageReference.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java (628667)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationStatistics.java (628667)
*Rob Davies* made the following changes at 12:50 PM, 18 February 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1583
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (628708)
*Rob Davies* made the following changes at 12:55 PM, 18 February 2008
Comment:
Apply patch for https://issues.apache.org/activemq/browse/AMQ-1584
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ClassLoadingAwareObjectInputStream.java (628710)
*Rob Davies* made the following changes at 01:00 PM, 18 February 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1506
> /activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ServerSessionPoolImpl.java (628711)
*aco* made the following changes at 02:52 PM, 18 February 2008
Comment:
Fix typo: https://issues.apache.org/activemq/browse/AMQ-1565
Added explicit version for maven-antrun-plugin
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFactory.java (628764)
> /activemq/trunk/pom.xml (628764)
*Rob Davies* made the following changes at 03:13 PM, 18 February 2008
Comment:
When recovering durable subscriptions - ensure they are recovered only once
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (628778)
*aco* made the following changes at 04:37 AM, 19 February 2008
Comment:
https://issues.apache.org/activemq/browse/AMQ-1580
- Check for 0 length buffer when receiving byte messages
- Don't send an empty byte message if there is no data to flush
- Added test case from AMQQ-1580
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQInputStream.java (628988)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQOutputStream.java (628988)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQInputStreamTest.java (628988)
*Rob Davies* made the following changes at 07:21 AM, 19 February 2008
Comment:
doDispatch():
only apply message to least loaded if target subscription not
already found
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (629007)
*aco* made the following changes at 10:46 AM, 19 February 2008
Comment:
- Fix for https://issues.apache.org/activemq/browse/AMQ-1576 (behavior is that if a jms property is null, it will not be converted, but will still be added to the default list of properties)
- Fix a spelling typo
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageTransformation.java (629060)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java (629060)
*Rob Davies* made the following changes at 10:12 AM, 20 February 2008
Comment:
updated properties
> /activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPAReferenceStoreAdapter.java (629405)
*Rob Davies* made the following changes at 09:47 PM, 20 February 2008
Comment:
check for null byte passed as parameter
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java (629623)
*Hiram Chirino* made the following changes at 10:05 PM, 20 February 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1591
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java (629631)
*Rob Davies* made the following changes at 10:19 PM, 20 February 2008
Comment:
removed unused imports
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpBufferedOutputStream.java (629636)
*Hiram Chirino* made the following changes at 10:24 PM, 20 February 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1591
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/jdbc/JDBCPersistenceAdapter.java (629639)
*Rob Davies* made the following changes at 08:13 AM, 21 February 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1560
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicSub.java (629713)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/QueueConsumerPriorityTest.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IOHelper.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/data/DataManagerImpl.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicMessageStore.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndexMBean.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/Index.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/MapContainer.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java (629713)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/RecoveryBrokerTest.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndex.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/container/MapContainerImpl.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/IndexMBean.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/ConduitBridge.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStoreAdapter.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/tree/TreeIndex.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationStatistics.java (629713)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java (629713)
*Rob Davies* made the following changes at 09:10 AM, 21 February 2008
Comment:
have backup off by default
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (629725)
*Hiram Chirino* made the following changes at 04:39 PM, 21 February 2008
Comment:
Gaurd against too many read checks happening back to back.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (629859)
*Hiram Chirino* made the following changes at 11:42 PM, 21 February 2008
Comment:
Fixing bug with qdox.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (630050)
*Rob Davies* made the following changes at 10:05 AM, 22 February 2008
Comment:
expose some methods to make it easier to test
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (630136)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (630136)
*Hiram Chirino* made the following changes at 05:03 PM, 22 February 2008
Comment:
https://issues.apache.org/activemq/browse/AMQ-1595
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (630253)
*Rob Davies* made the following changes at 02:34 PM, 26 February 2008
Comment:
added additional logging around ClassNotFoundException
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagementContext.java (631227)
*Rob Davies* made the following changes at 02:50 PM, 26 February 2008
Comment:
Introduced AbstractTempRegion - to cater for temp destination
usage on failover
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (631237)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractTempRegion.java (631237)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java (631237)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java (631237)
*Rob Davies* made the following changes at 02:55 PM, 26 February 2008
Comment:
removed tmp destination tests - the check is done client side now
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java (631240)
*Rob Davies* made the following changes at 02:56 PM, 26 February 2008
Comment:
Added network and fault tolerant flags to ConnectionContext
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (631241)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ConnectionContext.java (631241)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/Connection.java (631241)
*Rob Davies* made the following changes at 03:00 PM, 26 February 2008
Comment:
optionally replay messages on the fault tolerant transport
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/ResponseCorrelator.java (631244)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (631244)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionStateTracker.java (631244)
*James Strachan* made the following changes at 07:54 AM, 27 February 2008
Comment:
zap old code that has moved to actievmq-web
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/DurableSubscriberFacade.java (631508)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/LocalBrokerFacade.java (631508)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/BrokerFacadeSupport.java (631508)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/SessionPool.java (631508)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/MessageQuery.java (631508)
> /activemq/trunk/activemq-web-console/src/main/java/org/apache/activemq/web/QueueBrowseQuery.java (631508)
*James Strachan* made the following changes at 07:56 AM, 27 February 2008
Comment:
added a test case showing how to set a property using a Processor http://www.nabble.com/setting-JMSXGroupId-property-from-within-a-processor-tp15706825s22882p15706825.html
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/camel/SetHeaderTest-context.xml (631509)
> /activemq/trunk/activemq-core/src/test/data (631509)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/SetGroupIdProcessor.java (631509)
> /activemq/trunk/pom.xml (631509)
> /activemq/trunk/activemq-core/src/test/data/message1.xml (631509)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/SetHeaderTest.java (631509)
> /activemq/trunk/activemq-core/pom.xml (631509)
*Rob Davies* made the following changes at 10:21 AM, 27 February 2008
Comment:
recycle hash pages
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (631537)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (631537)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java (631537)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (631537)
*Hiram Chirino* made the following changes at 05:20 PM, 27 February 2008
Comment:
Adding a test does a load test across multiple network connections.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java (631658)
*Hiram Chirino* made the following changes at 05:44 PM, 27 February 2008
Comment:
Added better weighted sleeps to make sure everything is going before we start sampling.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java (631662)
*Hiram Chirino* made the following changes at 06:07 PM, 27 February 2008
Comment:
Better qos options on the producer of this test.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java (631665)
*James Strachan* made the following changes at 07:01 PM, 04 March 2008
Comment:
made the load test a bit bigger :)
> /activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/LoadTest-context.xml (633585)
*Hiram Chirino* made the following changes at 07:36 PM, 04 March 2008
Comment:
The AsyncDataManager now supports doing a callback notification for when a write
has been secured to disk.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (633603)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/NIODataFileAppender.java (633603)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessor.java (633603)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/JournalFacade.java (633603)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAppender.java (633603)
*Rob Davies* made the following changes at 09:32 AM, 05 March 2008
Comment:
Added non persistent queue network test
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNetworkTest.java (633799)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentQueueNetworkTest.java (633799)
*Rob Davies* made the following changes at 09:35 AM, 05 March 2008
Comment:
Added NonCachedMessageContext
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/MessageEvaluationContext.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ConnectionContext.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalPersistenceAdapter.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchSelector.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/filter/NonCachedMessageEvaluationContext.java (633800)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (633800)
*Rob Davies* made the following changes at 10:12 AM, 05 March 2008
Comment:
remove unused import
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (633806)
*Rob Davies* made the following changes at 10:17 AM, 05 March 2008
Comment:
synchronize around the messagesWaitingForSpace
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (633808)
*Hiram Chirino* made the following changes at 04:14 PM, 05 March 2008
Comment:
Added some property accessors
> /activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/BenchmarkSupport.java (633903)
> /activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/Producer.java (633903)
> /activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/benchmark/ProducerConsumer.java (633903)
*Rob Davies* made the following changes at 06:59 PM, 05 March 2008
Comment:
Define specific region classes for TempQueue and TempTopic
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (633976)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java (633976)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java (633976)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopic.java (633976)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (633976)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/IndirectMessageReference.java (633976)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (633976)
*James Strachan* made the following changes at 02:35 PM, 06 March 2008
Comment:
added support for http://issues.apache.org/activemq/browse/AMQ-1199 so that its easy to browse the available queues & topics in a broker
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationListener.java (634277)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java (634277)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (634277)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationEvent.java (634277)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/AdvisoryConsumerExample.java (634277)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/DestinationListenerTest.java (634277)
*James Strachan* made the following changes at 02:40 PM, 06 March 2008
Comment:
updated the test case for http://issues.apache.org/activemq/browse/AMQ-1199 to make it a better test
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/DestinationSource.java (634281)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/DestinationListenerTest.java (634281)
*James Strachan* made the following changes at 06:22 PM, 06 March 2008
Comment:
added a helper class for auto-exposing ActiveMQ Queues into the CamelContext
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java (634377)
*Hiram Chirino* made the following changes at 08:45 PM, 06 March 2008
Comment:
Fix for: https://issues.apache.org/activemq/browse/AMQ-1613
Avoid deadlocking with the thread calling oneway() when we are cleaning up the connection due to an Inactivity error.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (634411)
*Rob Davies* made the following changes at 08:09 PM, 07 March 2008
Comment:
Improvements to removing stale connections
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (634797)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/SingleTransportConnectionStateRegister.java (634797)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/cluster/ConnectionSplitBroker.java (634797)
*Rob Davies* made the following changes at 06:43 PM, 07 March 2008
Comment:
Ignore invalid commands to the AdvisoryConsumer- can happen due
to the use of wildcards across a network
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java (634775)
*James Strachan* made the following changes at 02:17 PM, 07 March 2008
Comment:
added support to be able to auto-expose ActiveMQ Queues into a CamelContext so that they are browsable by any Camel based tooling
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/CamelEndpointLoader.java (634686)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/AutoExposeQueuesInCamelTest.java (634686)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQComponent.java (634686)
> /activemq/trunk/pom.xml (634686)
*Rob Davies* made the following changes at 09:06 AM, 07 March 2008
Comment:
Detect clients fail over - that haven't removed themselves from
a brokee
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java (634589)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/cluster/ConnectionSplitBroker.java (634589)
*Rob Davies* made the following changes at 09:02 AM, 07 March 2008
Comment:
re-introduce optimize dispatch for queues
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueue.java (634588)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (634588)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (634588)
*Hiram Chirino* made the following changes at 02:33 AM, 07 March 2008
Comment:
Added a ReentrantReadWriteLock to guard against a service call executing while a connection is being shutdown.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (634505)
*Rob Davies* made the following changes at 01:01 AM, 07 March 2008
Comment:
dump an index
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (634490)
*Rob Davies* made the following changes at 12:59 AM, 07 March 2008
Comment:
Add foundation for monitoring split brokers from a clients view point
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (634488)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java (634488)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/cluster/ConnectionSplitBroker.java (634488)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/cluster (634488)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisorySupport.java (634488)
*Rob Davies* made the following changes at 12:57 AM, 07 March 2008
Comment:
resolve concurrent modification
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java (634487)
*Rob Davies* made the following changes at 12:10 AM, 07 March 2008
Comment:
Fix concurrent modification of pagedInMessages
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (634472)
*Rob Davies* made the following changes at 09:29 PM, 06 March 2008
Comment:
open up to more Configuration
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/TaskRunnerFactory.java (634421)
*Rob Davies* made the following changes at 09:26 PM, 06 March 2008
Comment:
reduce contention around stats on connection - thx for spotting this Hiram!
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (634420)
*Rob Davies* made the following changes at 09:02 PM, 06 March 2008
Comment:
fix current modification of linked list
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (634415)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java (634415)
*James Strachan* made the following changes at 06:41 PM, 04 March 2008
Comment:
added a load testing example using the latest camel dataset feature http://cwiki.apache.org/CAMEL/dataset.html
> /activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq (633580)
> /activemq/trunk/activemq-camel-loadtest/pom.xml (633580)
> /activemq/trunk/activemq-camel-loadtest/src/main/java/org/apache (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/resources/org (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq (633580)
> /activemq/trunk/activemq-camel-loadtest (633580)
> /activemq/trunk/activemq-camel-loadtest/src/main/java/org/apache/activemq/soaktest (633580)
> /activemq/trunk/activemq-camel-loadtest/src (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/java (633580)
> /activemq/trunk/activemq-camel-loadtest/src/main/java/org (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/resources/log4j.properties (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache (633580)
> /activemq/trunk/activemq-camel-loadtest/src/main/java/org/apache/activemq (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/resources (633580)
> /activemq/trunk/activemq-camel-loadtest/src/main (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest/LoadTest.java (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest/LoadTest-context.xml (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/resources/org/apache/activemq/soaktest (633580)
> /activemq/trunk/activemq-camel-loadtest/src/main/java (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/java/org (633580)
> /activemq/trunk/activemq-camel-loadtest/src/test/java/org/apache/activemq/soaktest (633580)
*Hiram Chirino* made the following changes at 05:55 PM, 04 March 2008
Comment:
Fixing edge case that does not normally occur. When marshalling a null object and size prefixing is disabled, we
were still prefixing the size of the data.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/openwire/OpenWireFormat.java (633571)
*Hiram Chirino* made the following changes at 05:52 PM, 04 March 2008
Comment:
Reduce contention by using an Atomic Reference.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/MutableBrokerFilter.java (633570)
*Hiram Chirino* made the following changes at 05:28 PM, 04 March 2008
Comment:
The testWildcardConsume has 1 consumer subscribe to 2 destiantions and made an assumption
that messages would delivered in the order published to the 2 different destinations. This is not correct
as the messages could queue up and get dispatched at different times. Updated the code so that this assumption
is no longer relied on.
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/BrokerTest.java (633554)
*Hiram Chirino* made the following changes at 06:03 PM, 03 March 2008
Comment:
Protect the messagesWaitingForSpace variable against concurrent modification.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (633210)
*Rob Davies* made the following changes at 07:18 AM, 03 March 2008
Comment:
Compress HashIndex on startup - only way to ensure the index
pages are loaded in correct order without changing the wire format
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (632964)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java (632964)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java (632964)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (632964)
*Rob Davies* made the following changes at 07:16 AM, 03 March 2008
Comment:
Don't use default container name for loader test
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/Loader.java (632963)
*Rob Davies* made the following changes at 07:15 AM, 03 March 2008
Comment:
HashTest expanded to load/unload/load indexes through testing
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/kaha/impl/index/hash/HashTest.java (632962)
*Rob Davies* made the following changes at 07:14 AM, 03 March 2008
Comment:
Added copy file method
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/IOHelper.java (632961)
*Rob Davies* made the following changes at 10:31 PM, 01 March 2008
Comment:
make splitting consumers/producers memory limit optional and off
by default
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (632666)
*Rob Davies* made the following changes at 07:59 PM, 01 March 2008
Comment:
fix for inaccurate page calculation in bin overflow
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashBin.java (632651)
*Rob Davies* made the following changes at 07:30 AM, 01 March 2008
Comment:
reset defaults
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (632560)
*Hiram Chirino* made the following changes at 09:59 PM, 29 February 2008
Comment:
The Producer MemoryLimit can lead to network deadlock when spooling is disabled.
So we now disable using it when sooling is used on a queue.
see:
https://issues.apache.org/activemq/browse/AMQ-1606
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTempQueueRegion.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java (632455)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (632455)
*Rob Davies* made the following changes at 02:55 PM, 29 February 2008
Comment:
set track messages off by default
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (632333)
*Rob Davies* made the following changes at 09:22 AM, 29 February 2008
Comment:
Move back to using DEfaultThreadPools for reconnect tasks - as
for very bad connections, DedicatedTaskRunner could get swamped with
reconnect tasks
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (632269)
*Rob Davies* made the following changes at 04:45 PM, 28 February 2008
Comment:
remove println() - oops
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (632051)
*Rob Davies* made the following changes at 04:42 PM, 28 February 2008
Comment:
changed free list implementation
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashIndex.java (632050)
*Rob Davies* made the following changes at 04:38 PM, 28 February 2008
Comment:
added size to toString() method
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPage.java (632047)
*Rob Davies* made the following changes at 04:36 PM, 28 February 2008
Comment:
added toString()
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/hash/HashPageInfo.java (632046)
*Rob Davies* made the following changes at 01:29 PM, 28 February 2008
Comment:
keep alive should get a response
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (631965)
*aco* made the following changes at 06:45 AM, 28 February 2008
Comment:
Upgraded jettison to 1.0
https://issues.apache.org/activemq/browse/AMQ-1597
> /activemq/trunk/activemq-core/pom.xml (631871)
*aco* made the following changes at 06:24 AM, 28 February 2008
Comment:
Tweak the logging a bit. Didn't like the idea of different log messages depending on log level.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (631866)
*aco* made the following changes at 06:20 AM, 28 February 2008
Comment:
Changing logging to log stacktraces to debug only
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (631864)
*aco* made the following changes at 05:12 AM, 28 February 2008
Comment:
https://issues.apache.org/activemq/browse/AMQ-1598
Remove extraneous Thread.dumpStack call
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java (631848)
*James Strachan* made the following changes at 02:51 PM, 06 February 2008
Comment:
Use a larger send batch by default on the sample
> /activemq/trunk/assembly/src/release/example/src/TopicPublisher.java (619005)
*Hiram Chirino* made the following changes at 02:48 PM, 06 February 2008
Comment:
- Clients do not shutdown due to non-daemon threads hanging around.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/InactivityMonitor.java (619004)
*Rob Davies* made the following changes at 12:23 PM, 06 February 2008
Comment:
Reduce contention on the AMQ Store
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/ReferenceStore.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/memory/MemoryTopicMessageStore.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/RecoveryListenerAdapter.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (618981)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java (618981)
*Rob Davies* made the following changes at 11:08 PM, 05 February 2008
Comment:
comment out send first then consume
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/region/cursors/CursorSupport.java (618817)
*Rob Davies* made the following changes at 08:52 PM, 05 February 2008
Comment:
return a lock for the store
> /activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPAReferenceStore.java (618774)
*Rob Davies* made the following changes at 04:20 PM, 05 February 2008
Comment:
lock dispatching (again) whilst adding a consumer
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (618689)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (618689)
*Rob Davies* made the following changes at 02:06 PM, 05 February 2008
Comment:
add isConnected() flag to a Transport
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportSupport.java (618656)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransport.java (618656)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java (618656)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/ServiceSupport.java (618656)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFilter.java (618656)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java (618656)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (618656)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java (618656)
*Rob Davies* made the following changes at 02:05 PM, 05 February 2008
Comment:
copy message before resend
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/BrokerSupport.java (618655)
*Rob Davies* made the following changes at 02:04 PM, 05 February 2008
Comment:
Make maximum page size for queues configurable
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (618654)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (618654)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (618654)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (618654)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (618654)
*Rob Davies* made the following changes at 12:14 PM, 05 February 2008
Comment:
refactored cursors to improve re-use
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Subscription.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (618621)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractStoreCursor.java (618621)
*Rob Davies* made the following changes at 12:11 PM, 05 February 2008
Comment:
increase the length of the wait for messages
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/QueueSubscriptionTest.java (618620)
*Rob Davies* made the following changes at 12:07 PM, 05 February 2008
Comment:
removed test waiting for space
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/MessageExpirationTest.java (618619)
*Rob Davies* made the following changes at 12:05 PM, 05 February 2008
Comment:
Updated the performance tests
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/AMQStoreDurableTopicTest.java (618617)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfConsumer.java (618617)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleQueueTest.java (618617)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/SimpleNonPersistentQueueTest.java (618617)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfProducer.java (618617)
*Rob Davies* made the following changes at 12:01 PM, 05 February 2008
Comment:
don't set memory limit
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQStackOverFlowTest.java (618615)
*Rob Davies* made the following changes at 11:45 AM, 05 February 2008
Comment:
remove unused imports
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/EmbeddedBrokerTestSupport.java (618612)
*Hiram Chirino* made the following changes at 08:43 PM, 03 February 2008
Comment:
Adding a ReadOnlyAsyncDataManager so that you can access a set of data files in a read only way.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (618082)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ReadOnlyAsyncDataManager.java (618082)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java (618082)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/ReadOnlyDataFile.java (618082)
*Rob Davies* made the following changes at 06:34 AM, 31 January 2008
Comment:
added isDisposed to Transport interface
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/BackupTransport.java (617015)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportSupport.java (617015)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/mock/MockTransport.java (617015)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/fanout/FanoutTransport.java (617015)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportFilter.java (617015)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java (617015)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (617015)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java (617015)
*Rob Davies* made the following changes at 04:42 PM, 30 January 2008
Comment:
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/BackupTransport.java (616811)
*Rob Davies* made the following changes at 12:14 PM, 30 January 2008
Comment:
Further enhancement for https://issues.apache.org/activemq/browse/AMQ-1572
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (616735)
*Rob Davies* made the following changes at 12:10 PM, 30 January 2008
Comment:
Further enhancement for https://issues.apache.org/activemq/browse/AMQ-1572
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (616733)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/Transport.java (616733)
*Rob Davies* made the following changes at 08:06 PM, 29 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1572
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (616506)
*Rob Davies* made the following changes at 09:06 PM, 25 January 2008
Comment:
disable caching of messages for the Queue Cursor
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (615341)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (615341)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (615341)
*Rob Davies* made the following changes at 06:25 PM, 25 January 2008
Comment:
turn cache off by default
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (615297)
*Rob Davies* made the following changes at 05:56 PM, 25 January 2008
Comment:
disable optimized dispatch
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (615288)
*Rob Davies* made the following changes at 05:52 PM, 25 January 2008
Comment:
use task runner to dispatch messages - improve concurrency
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (615287)
*Rob Davies* made the following changes at 08:08 PM, 23 January 2008
Comment:
resolution for https://issues.apache.org/activemq/browse/AMQ-1566
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (614645)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (614645)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (614645)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/PendingMessageCursor.java (614645)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java (614645)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (614645)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (614645)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsDurableTopicSlowReceiveTest.java (614645)
*Rob Davies* made the following changes at 02:28 PM, 22 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1562
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingSubscriberMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingSubscriberMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingQueueMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreQueueCursor.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingQueueMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingDurableSubscriberMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/VMPendingDurableSubscriberMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/FilePendingQueueMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingSubscriberMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingDurableSubscriberMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/StoreDurableSubscriberCursor.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PendingDurableSubscriberMessageStoragePolicy.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java (614206)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/StorePendingQueueMessageStoragePolicy.java (614206)
*Rob Davies* made the following changes at 02:22 PM, 21 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1475
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/usage/Usage.java (613899)
*James Strachan* made the following changes at 01:48 PM, 21 January 2008
Comment:
Lowered the logging level of empty messages returned. For background see : http://www.nabble.com/HTTP-%3A-Received-null-command-tp14997476s2354p14997476.html
> /activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java (613889)
*Rob Davies* made the following changes at 01:09 PM, 21 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1560
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (613874)
*Rob Davies* made the following changes at 10:33 AM, 21 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1559
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java (613832)
*Rob Davies* made the following changes at 10:31 AM, 21 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1510
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/DestinationViewMBean.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFactoryImpl.java (613830)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (613830)
*Rob Davies* made the following changes at 10:28 AM, 21 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1556
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java (613829)
*Rob Davies* made the following changes at 07:49 PM, 18 January 2008
Comment:
increase the amount of time to receive messages - to try prevent intermittent failure
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/DurableConsumerTest.java (613244)
*Rob Davies* made the following changes at 07:16 PM, 18 January 2008
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1553
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java (613230)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java (613230)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (613230)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/SimpleDispatchPolicy.java (613230)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/ProducerEventSource.java (613230)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (613230)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (613230)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (613230)
*Rob Davies* made the following changes at 06:18 PM, 17 January 2008
Comment:
resources for the sharedFileMaster tests
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/ft/sharedFileSlave.xml (612910)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/ft/sharedFileMaster.xml (612910)
*James Strachan* made the following changes at 02:31 PM, 17 January 2008
Comment:
added a test case and fix for AMQ-775 along with a useful base class for testing ActiveMQ using Camel
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/message/security/MessageAuthenticationTest.java (612828)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/message (612828)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (612828)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/message/security (612828)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnector.java (612828)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/CamelEmbeddedBrokerTestSupport.java (612828)
*James Strachan* made the following changes at 02:20 PM, 17 January 2008
Comment:
added a little helper factory bean for https://issues.apache.org/activemq/browse/AMQ-1552 to allow easy failover configuration without explicit URI magic
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/spring/ActiveMQConnectionFactoryFactoryBean.java (612824)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/spring/ActiveMQConnectionFactoryFactoryBeanTest.java (612824)
*James Strachan* made the following changes at 02:19 PM, 17 January 2008
Comment:
fixed the schema location
> /activemq/trunk/activemq-core/src/test/resources/spring-embedded-xbean.xml (612823)
*Hiram Chirino* made the following changes at 12:48 AM, 17 January 2008
Comment:
Applying https://issues.apache.org/activemq/browse/AMQ-1361
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerControlMBean.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLogger.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/logwriters/DefaultLogWriter.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/SslTransportFactory.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java (612661)
> /activemq/trunk/activemq-console/src/test/resources/activemq.xml (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/LogWriter.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/logwriters/CustomLogWriter.java (612661)
> /activemq/trunk/activemq-console/src/test/resources/log4j.properties (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportFactory.java (612661)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/logwriters/custom (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LogWriterFinder.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerFactory.java (612661)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/logwriters/default (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerControl.java (612661)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/logwriters (612661)
> /activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpTransportFactory.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerViewMBean.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/TransportLoggerView.java (612661)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/logwriters (612661)
*Hiram Chirino* made the following changes at 07:29 PM, 16 January 2008
Comment:
Applying patch: https://issues.apache.org/activemq/browse/AMQ-1493 Thx Dejan.
> /activemq/trunk/activemq-optional/pom.xml (612548)
> /activemq/trunk/activemq-web-console/pom.xml (612548)
> /activemq/trunk/activemq-web-demo/pom.xml (612548)
> /activemq/trunk/activemq-web/pom.xml (612548)
> /activemq/trunk/pom.xml (612548)
> /activemq/trunk/assembly/pom.xml (612548)
*Hiram Chirino* made the following changes at 07:15 PM, 16 January 2008
Comment:
Applying patch at https://issues.apache.org/activemq/browse/AMQ-943
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/frametranslator/jms-xml (612544)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompTransportFilter.java (612544)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/SamplePojo.java (612544)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompSubscription.java (612544)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/XStreamFrameTranslator.java (612544)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java (612544)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Stomp.java (612544)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/frametranslator (612544)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/activemq/transport/frametranslator/jms-json (612544)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java (612544)
> /activemq/trunk/activemq-core/pom.xml (612544)
*Rob Davies* made the following changes at 07:03 PM, 16 January 2008
Comment:
Add producers to DestinationStatistics
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationStatistics.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (612542)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (612542)
*Rob Davies* made the following changes at 01:56 PM, 16 January 2008
Comment:
set correct consumer count on consumer advisories
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (612459)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java (612459)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Region.java (612459)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerFilter.java (612459)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java (612459)
*Hiram Chirino* made the following changes at 08:29 PM, 14 January 2008
Comment:
Fixing the build. Backing down the xbean version until the qdox parser problem is resolved.
> /activemq/trunk/pom.xml (611918)
> /activemq/trunk/activemq-core/pom.xml (611918)
*Hiram Chirino* made the following changes at 06:44 PM, 09 January 2008
Comment:
Upgrade to xbean 3.3-SNAPSHOT to pull in the fix for:
http://issues.apache.org/jira/browse/XBEAN-101
PropertyPlaceholderConfigurer can not be used to resolve values assigned to xbean properties that have a custom PropertyEditor
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/memory/usage.properties (610502)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/memory/activemq.xml (610502)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/memory (610502)
> /activemq/trunk/pom.xml (610502)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/memory/MemoryPropertyTest.java (610502)
*Rob Davies* made the following changes at 04:16 PM, 09 January 2008
Comment:
applied patch for https://issues.apache.org/activemq/browse/AMQ-1542
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java (610432)
*Rob Davies* made the following changes at 01:51 PM, 07 January 2008
Comment:
fixes for load testing
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java (609606)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/QueueStorePrefetch.java (609606)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/load/LoadTest.java (609606)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/TopicStorePrefetch.java (609606)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/load/LoadController.java (609606)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/load/LoadClient.java (609606)
*Hiram Chirino* made the following changes at 09:38 PM, 04 January 2008
Comment:
Fix for http://issues.apache.org/activemq/browse/AMQ-1519
Start up the embeded broker in an async thread so that it does not block the AppServer startup if a slave broker is started.
> /activemq/trunk/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQResourceAdapter.java (609016)
*Hiram Chirino* made the following changes at 06:56 PM, 04 January 2008
Comment:
activemq-all was missing the commons-logging required dependency.
> /activemq/trunk/activemq-all/pom.xml (608958)
*Rob Davies* made the following changes at 04:07 PM, 04 January 2008
Comment:
Added basic load test for queues
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/load (608902)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/load/LoadTest.java (608902)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/load/LoadController.java (608902)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/load/LoadClient.java (608902)
> /activemq/trunk/activemq-core/pom.xml (608902)
*Rob Davies* made the following changes at 10:03 AM, 03 January 2008
Comment:
nake inflight message count a little more explicit
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionViewMBean.java (608414)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java (608414)
*Rob Davies* made the following changes at 06:34 AM, 03 January 2008
Comment:
Add some duplex property for network connector view
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/NetworkConnectorViewMBean.java (608356)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java (608356)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/NetworkConnectorView.java (608356)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (608356)
*James Strachan* made the following changes at 11:23 AM, 02 January 2008
Comment:
added an example of how to specify the maximum number of active JDBC connections
> /activemq/trunk/assembly/src/release/conf/activemq.xml (608084)
*aco* made the following changes at 09:51 AM, 02 January 2008
Comment:
Update to the Java Service Wrapper
> /activemq/trunk/assembly/src/release/bin/macosx/wrapper.conf (608064)
> /activemq/trunk/assembly/src/release/bin/linux/wrapper.conf (608064)
> /activemq/trunk/assembly/src/main/descriptors/windows-bin.xml (608064)
> /activemq/trunk/assembly/src/release/bin/win32/wrapper.conf (608064)
*jlim* made the following changes at 09:47 AM, 17 October 2007
Comment:
updates for https://issues.apache.org/activemq/browse/AMQ-1311
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java (585413)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (585413)
*Rob Davies* made the following changes at 06:07 AM, 17 October 2007
Comment:
update to show producerFlowControl and memoryLimit is configurable
on a Destination basis via destination policies
> /activemq/trunk/assembly/src/release/conf/activemq.xml (585377)
*Rob Davies* made the following changes at 06:05 AM, 17 October 2007
Comment:
Make producerFlowControl configurable per Destination
default=true
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java (585375)
> /activemq/trunk/activemq-core/src/test/resources/org/apache/activemq/broker/policy/cursor.xml (585375)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Destination.java (585375)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/BaseDestination.java (585375)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/policy/DestinationCursorConfigTest.java (585375)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (585375)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (585375)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java (585375)
*Rob Davies* made the following changes at 07:25 PM, 16 October 2007
Comment:
don't wait for ever to stop
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/perf/PerfProducer.java (585215)
*Hiram Chirino* made the following changes at 05:22 PM, 16 October 2007
Comment:
Updated the flow control logic for the Topic case to match what we are using for the Queue case
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java (585187)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (585187)
*Rob Davies* made the following changes at 11:53 AM, 16 October 2007
Comment:
no need to call force() on commit as the reference store gets rebuilt on failure
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (585109)
*Rob Davies* made the following changes at 06:46 AM, 16 October 2007
Comment:
change number of messages -was hanging waiting space
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/test/rollback/RollbacksWhileConsumingLargeQueueTest.java (585047)
*Rob Davies* made the following changes at 06:01 AM, 16 October 2007
Comment:
updated to take account of new System Usage
> /activemq/trunk/assembly/src/release/conf/activemq.xml (585040)
*Rob Davies* made the following changes at 10:36 PM, 15 October 2007
Comment:
fix for npe
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (584929)
*Rob Davies* made the following changes at 08:31 PM, 15 October 2007
Comment:
fix data logs not being correctly removed
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQMessageStore.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQTopicMessageStore.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFile.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/TopicReferenceStore.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/TopicSubContainer.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStore.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/TopicMessageStore.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/DataFileAccessorPool.java (584863)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaTopicReferenceStore.java (584863)
*Rob Davies* made the following changes at 08:29 PM, 15 October 2007
Comment:
implement acknowledgeReference() for TopicReferenceStore
> /activemq/trunk/activemq-jpa-store/src/main/java/org/apache/activemq/store/jpa/JPATopicReferenceStore.java (584862)
*Hiram Chirino* made the following changes at 03:50 PM, 15 October 2007
Comment:
Fix for a failover transport deadlock that could occur if the transport is stopped at the same time a failure occurs.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java (584800)
*Rob Davies* made the following changes at 06:27 AM, 12 October 2007
Comment:
Applied patch associated with:
https://issues.apache.org/activemq/browse/AMQ-358
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/LdapNetworkConnector.java (584047)
*Rob Davies* made the following changes at 09:58 PM, 11 October 2007
Comment:
Expose properties for configuring the asyncDataManager
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java (583949)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (583949)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (583949)
*Rob Davies* made the following changes at 08:53 PM, 10 October 2007
Comment:
Fix for NPE in duplex network connection
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/MapTransportConnectionStateRegister.java (583595)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java (583595)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (583595)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/network/SimpleNetworkTest.java (583595)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnectionState.java (583595)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/SingleTransportConnectionStateRegister.java (583595)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnectionStateRegister.java (583595)
*Rob Davies* made the following changes at 07:28 PM, 10 October 2007
Comment:
removed System.out
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueTest.java (583571)
*Rob Davies* made the following changes at 06:45 PM, 09 October 2007
Comment:
add some more useful methods
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageAudit.java (583237)
*James Strachan* made the following changes at 04:14 PM, 09 October 2007
Comment:
include the STAX API jars in the distro
> /activemq/trunk/assembly/pom.xml (583188)
*James Strachan* made the following changes at 03:44 PM, 09 October 2007
Comment:
added a plugin to support invocation of MessageListener classes as a bean in Camel; for more information see: http://cwiki.apache.org/CAMEL/activemq.html
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQMessageConverter.java (583185)
*James Strachan* made the following changes at 03:44 PM, 09 October 2007
Comment:
added a plugin to support invocation of MessageListener classes as a bean in Camel; for more information see: http://cwiki.apache.org/CAMEL/activemq.html
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/ActiveMQConverter.java (583184)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/converter/ActiveMQMessageConverter.java (583184)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/converter (583184)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/component/ActiveMQReplyToHeaderUsingConverterTest.java (583184)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/converter (583184)
> /activemq/trunk/activemq-core/src/main/resources/META-INF/services/org/apache/camel/TypeConverter (583184)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/converter/package.html (583184)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/converter/ActiveMQConverter.java (583184)
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/converter/InvokeMessageListenerTest.java (583184)
*James Strachan* made the following changes at 02:35 PM, 09 October 2007
Comment:
updated javadoc link
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java (583163)
*James Strachan* made the following changes at 12:28 PM, 09 October 2007
Comment:
updated the javadoc to be more clear about the camel support
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/component/package.html (583114)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/camel/package.html (583114)
> /activemq/trunk/activemq-core/pom.xml (583114)
*Rob Davies* made the following changes at 06:47 PM, 08 October 2007
Comment:
quick fix for npe
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/VMIndexLinkedList.java (582910)
*Rob Davies* made the following changes at 04:10 PM, 08 October 2007
Comment:
make persistentIndex true by default
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java (582839)
*Rob Davies* made the following changes at 01:54 PM, 08 October 2007
Comment:
set options on the discovery agent correctly from the URI
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/discovery/simple/SimpleDiscoveryAgentFactory.java (582810)
*Rob Davies* made the following changes at 01:39 PM, 08 October 2007
Comment:
Add properties to the AMQPersistenceAdaptorFactory
to set syncOnWrite(default=false) and persistentIndex(default=true) properties
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (582801)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapterFactory.java (582801)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java (582801)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/Store.java (582801)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (582801)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java (582801)
*Rob Davies* made the following changes at 06:10 AM, 07 October 2007
Comment:
refresh entry for prev as well as next
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java (582575)
*Rob Davies* made the following changes at 05:42 AM, 07 October 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1445
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/index/DiskIndexLinkedList.java (582574)
*Rob Davies* made the following changes at 07:02 AM, 05 October 2007
Comment:
patch http://issues.apache.org/activemq/browse/AMQ-1444
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java (582086)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java (582086)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java (582086)
*Rob Davies* made the following changes at 02:01 PM, 04 October 2007
Comment:
Test case for sending single messages per connection - was blowing memory - now fixed
> /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/ConnectionPerMessageTest.java (581885)
*Rob Davies* made the following changes at 01:49 PM, 04 October 2007
Comment:
the MESSAGE_SIZE_OVERHEAD was too low - increased it to a more realistic size
Please note - this is related to the overhead in broker memory - not
the on-the-wire size - which is small
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java (581882)
*Rob Davies* made the following changes at 01:48 PM, 04 October 2007
Comment:
By default, use no subscription recovery policy for temporary or advisory topics
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java (581881)
*Rob Davies* made the following changes at 09:00 AM, 04 October 2007
Comment:
handle errors from recovery check gracefully
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java (581792)
*Rob Davies* made the following changes at 07:18 AM, 04 October 2007
Comment:
FilePendingMessageCursor was being added twice to the MemoryUsage
which resulted in a memory leak
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/FilePendingMessageCursor.java (581784)
*Hiram Chirino* made the following changes at 12:32 AM, 04 October 2007
Comment:
Fix for https://issues.apache.org/activemq/browse/AMQ-1038
We now send REDELIVERY acks to the broker when a message is redelivered. This allows the broker to update the message with the number of times redelivery has occured so that if the message is delivered to another consumer it can DQL the message when max redeliveries have occured across consumers.
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageAck.java (581747)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java (581747)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java (581747)
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQSession.java (581747)
*Rob Davies* made the following changes at 10:55 PM, 03 October 2007
Comment:
after canceling a TimerTask - purge from the Timer list - fix memory leak
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/thread/Scheduler.java (581736)
*Rob Davies* made the following changes at 09:24 PM, 03 October 2007
Comment:
Fix for http://issues.apache.org/activemq/browse/AMQ-1250
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java (581715)
*Rob Davies* made the following changes at 07:50 PM, 03 October 2007
Comment:
fix memory leak in ActiveMQConnection - with asyncConnectionThread not being shutdown on a close
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java (581683)
*Rob Davies* made the following changes at 12:24 PM, 03 October 2007
Comment:
Ignore NULL references when checking isEmpty
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/VMPendingMessageCursor.java (581568)
*Rob Davies* made the following changes at 06:58 PM, 02 October 2007
Comment:
be conservative allocating objects up-front
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/util/LRUCache.java (581321)
*Rob Davies* made the following changes at 02:58 PM, 02 October 2007
Comment:
Have the TransactionContext per connection
> /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/TransactionContext.java (581242)
---------------------------------------------------------------------------------------
The build has 6 failed tests and 1789 successful tests.
Click http://bamboo.logicblaze.com:8085/browse/AMQ-DEF-187 to find out more.
Thanks,
Bamboo
|