summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2013-08-21 16:28:21 +0000
committerRobert Godfrey <rgodfrey@apache.org>2013-08-21 16:28:21 +0000
commita607830490b4b64a25f64c1e8a79662ef7ab95e8 (patch)
treed446dbb2bb95b35f8ed773f2f23a50459ce23199 /qpid/java/broker/src
parent1b0f9f406925254854c2a2c204a1ae0efbf1874f (diff)
downloadqpid-python-a607830490b4b64a25f64c1e8a79662ef7ab95e8.tar.gz
QPID-5087 : [Java Broker] Fix test to mock restoreQueue/Exchange rather than createQueue/Exchange
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1516204 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src')
-rw-r--r--qpid/java/broker/src/test/java/org/apache/qpid/server/virtualhost/DurableConfigurationRecovererTest.java10
1 files changed, 4 insertions, 6 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/virtualhost/DurableConfigurationRecovererTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/virtualhost/DurableConfigurationRecovererTest.java
index d793895e7f..987a541d05 100644
--- a/qpid/java/broker/src/test/java/org/apache/qpid/server/virtualhost/DurableConfigurationRecovererTest.java
+++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/virtualhost/DurableConfigurationRecovererTest.java
@@ -123,8 +123,8 @@ public class DurableConfigurationRecovererTest extends QpidTestCase
_queueFactory = mock(QueueFactory.class);
- when(_queueFactory.createQueue(idArg.capture(), queueArg.capture(),
- anyBoolean(), anyString(), anyBoolean(), anyBoolean(), anyBoolean(), argsArg.capture())).then(
+ when(_queueFactory.restoreQueue(idArg.capture(), queueArg.capture(),
+ anyString(), anyBoolean(), anyBoolean(), anyBoolean(), argsArg.capture())).then(
new Answer()
{
@@ -270,10 +270,9 @@ public class DurableConfigurationRecovererTest extends QpidTestCase
final Exchange customExchange = mock(Exchange.class);
- when(_exchangeFactory.createExchange(eq(customExchangeId),
+ when(_exchangeFactory.restoreExchange(eq(customExchangeId),
eq(CUSTOM_EXCHANGE_NAME),
eq(HeadersExchange.TYPE.getType()),
- anyBoolean(),
anyBoolean())).thenReturn(customExchange);
final ConfiguredObjectRecord[] expected = {
@@ -387,10 +386,9 @@ public class DurableConfigurationRecovererTest extends QpidTestCase
when(customExchange.getId()).thenReturn(exchangeId);
when(customExchange.getName()).thenReturn(CUSTOM_EXCHANGE_NAME);
- when(_exchangeFactory.createExchange(eq(exchangeId),
+ when(_exchangeFactory.restoreExchange(eq(exchangeId),
eq(CUSTOM_EXCHANGE_NAME),
eq(HeadersExchange.TYPE.getType()),
- anyBoolean(),
anyBoolean())).thenReturn(customExchange);
_durableConfigurationRecoverer.beginConfigurationRecovery(_store, 2);