activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bamboo <bam...@logicblaze.com>
Subject [Bamboo] Apache ActiveMQ - NightSite build 233 has FAILED. Change made by Rob Davies and Hiram Chirino
Date Sun, 09 Dec 2007 03:01:55 GMT
The project Apache ActiveMQ - NightSite has the following 8 changes by 2 authors:

*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)
*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 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 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 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)
*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)
*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 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)

        

---------------------------------------------------------------------------------------

No tests were executed.

Click http://bamboo.logicblaze.com:8085/browse/AMQ-N2-233 to find out more.

Thanks,

Bamboo

Mime
View raw message