activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r805873 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store: amq/AMQPersistenceAdapter.java kahadaptor/KahaPersistenceAdapter.java
Date Wed, 19 Aug 2009 16:38:45 GMT
Author: rajdavies
Date: Wed Aug 19 16:38:45 2009
New Revision: 805873

URL: http://svn.apache.org/viewvc?rev=805873&view=rev
Log:
Apply patch for http://issues.apache.org/activemq/browse/AMQ-1998

Modified:
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
    activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java?rev=805873&r1=805872&r2=805873&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
Wed Aug 19 16:38:45 2009
@@ -501,7 +501,8 @@
      * @param destination
      */
     public void removeQueueMessageStore(ActiveMQQueue destination) {
-        queues.remove(destination);
+        AMQMessageStore store= queues.remove(destination);
+        referenceStoreAdapter.removeQueueMessageStore(destination);
     }
 
     /**

Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java?rev=805873&r1=805872&r2=805873&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
(original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaPersistenceAdapter.java
Wed Aug 19 16:38:45 2009
@@ -141,6 +141,13 @@
      */
     public void removeQueueMessageStore(ActiveMQQueue destination) {
         queues.remove(destination);
+        try{
+        	if(theStore!=null){
+        		theStore.deleteMapContainer(destination,"queue-data");
+        	}
+        }catch(IOException e ){
+        	LOG.error("Failed to remove store map container for queue:"+destination, e);
+        }
     }
 
     /**



Mime
View raw message