Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixing regression caused by changes to SuppressRelyException in commit b0e91d47f5.

This commit is contained in:
Hiram Chirino 2013-12-02 12:29:21 -05:00
parent cfeea7797d
commit 61e13fa6ce
2 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-leveldb-store/src/main/scala/org/apache/activemq/leveldb/LevelDBStore.scala
View File

@ -437,13 +437,13 @@ class LevelDBStore extends LockableServiceSupport with BrokerServiceAware with P
def verify_running = { def verify_running = {
if( isStopping || isStopped ) { if( isStopping || isStopped ) {
try { try {
throw new SuppressReplyException("Not running") throw new IOException("Not running")
} catch { } catch {
case e:IOException => case e:IOException =>
if( broker_service!=null ) { if( broker_service!=null ) {
broker_service.handleIOException(e) broker_service.handleIOException(e)
} }
throw e throw new SuppressReplyException(e);
} }
} }
} }

3
activemq-unit-tests/src/test/java/org/apache/activemq/store/LevelDBStorePerDestinationTest.java
View File

@ -18,7 +18,6 @@ package org.apache.activemq.store;
import org.apache.activemq.leveldb.LevelDBStore; import org.apache.activemq.leveldb.LevelDBStore;
import org.junit.Test; import org.junit.Test;
import org.junit.Ignore;
import java.io.IOException; import java.io.IOException;
@ -35,12 +34,10 @@ public class LevelDBStorePerDestinationTest extends StorePerDestinationTest {
return store; return store;
} }
@Ignore("needs some investigation w.r.t to SuppressReplyException - broken by: https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=commit;h=b0e91d47")
@Test @Test
@Override @Override
public void testRollbackRecovery() throws Exception {} public void testRollbackRecovery() throws Exception {}
@Ignore("needs some investigation w.r.t to SuppressReplyException - broken by: https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=commit;h=b0e91d47")
@Test @Test
@Override @Override
public void testCommitRecovery() throws Exception {} public void testCommitRecovery() throws Exception {}