diff options
| author | Alex Rudyy <orudyy@apache.org> | 2014-07-04 14:00:14 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2014-07-04 14:00:14 +0000 |
| commit | 8f8e23c83979091691e160dcb4978b2a83a7e551 (patch) | |
| tree | 989f500c035a5d28cb7ae00cd67ef31eded183a1 /qpid/java | |
| parent | b9bc2e95fcc5698e2d6e36bd490b7cfe1fcc81ca (diff) | |
| download | qpid-python-8f8e23c83979091691e160dcb4978b2a83a7e551.tar.gz | |
QPID-5875: Fix intruder protection system test
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1607860 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBHAVirtualHostNodeRestTest.java | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBHAVirtualHostNodeRestTest.java b/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBHAVirtualHostNodeRestTest.java index 1b904c94a4..cfa9557977 100644 --- a/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBHAVirtualHostNodeRestTest.java +++ b/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBHAVirtualHostNodeRestTest.java @@ -281,9 +281,17 @@ public class BDBHAVirtualHostNodeRestTest extends QpidRestTestCase envConfig.setAllowCreate(true); envConfig.setTransactional(true); envConfig.setDurability(Durability.parse((String)nodeData.get(BDBHAVirtualHostNode.DURABILITY))); - ReplicatedEnvironment intruder = new ReplicatedEnvironment(environmentPathFile, replicationConfig, envConfig); - waitForAttributeChanged(_baseNodeRestUrl + NODE1, VirtualHost.STATE, State.ERRORED.name()); + ReplicatedEnvironment intruder = null; + try + { + intruder = new ReplicatedEnvironment(environmentPathFile, replicationConfig, envConfig); + } + finally + { + intruder.close(); + } + waitForAttributeChanged(_baseNodeRestUrl + NODE1, VirtualHostNode.STATE, State.ERRORED.name()); } private void createHANode(String nodeName, int nodePort, int helperPort) throws Exception |