summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2013-08-16 10:23:51 +0000
committerRobert Godfrey <rgodfrey@apache.org>2013-08-16 10:23:51 +0000
commit2bc8d87a2fe3e8b1140b7c3499a85527aa3a63d7 (patch)
tree6b68739a6f60fb1ccb33c0bc82bb114905836e8c /qpid/java
parente80a585caa90715069cd66e19ce40f0859086149 (diff)
downloadqpid-python-2bc8d87a2fe3e8b1140b7c3499a85527aa3a63d7.tar.gz
QPID-5073 : Add dependency on alternate exchange for queues where such an alternate is set
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1514640 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/broker/src/test/java/org/apache/qpid/server/virtualhost/DurableConfigurationRecovererTest.java32
1 files changed, 15 insertions, 17 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 6a97eb38cb..2d3483f078 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
@@ -141,22 +141,6 @@ public class DurableConfigurationRecovererTest extends QpidTestCase
}
}).when(_queueRegistry).registerQueue(registeredQueue.capture());
- /* These lines necessary to get queue creation to work because AMQQueueFactory is called directly rather than
- queue creation being on vhost - yuck! */
- SecurityManager securityManager = mock(SecurityManager.class);
- when(_vhost.getSecurityManager()).thenReturn(securityManager);
- when(securityManager.authoriseCreateQueue(anyBoolean(),anyBoolean(),anyBoolean(),anyBoolean(),anyBoolean(),
- any(AMQShortString.class),anyString())).thenReturn(true);
- VirtualHostConfiguration configuration = mock(VirtualHostConfiguration.class);
- when(_vhost.getConfiguration()).thenReturn(configuration);
- QueueConfiguration queueConfiguration = mock(QueueConfiguration.class);
- when(configuration.getQueueConfiguration(anyString())).thenReturn(queueConfiguration);
- LogActor logActor = mock(LogActor.class);
- CurrentActor.set(logActor);
- RootMessageLogger rootLogger = mock(RootMessageLogger.class);
- when(logActor.getRootMessageLogger()).thenReturn(rootLogger);
- /* end of queue creation mock hackery */
-
_exchangeFactory = mock(ExchangeFactory.class);
DurableConfiguredObjectRecoverer[] recoverers = {
@@ -372,7 +356,21 @@ public class DurableConfigurationRecovererTest extends QpidTestCase
final UUID queueId = new UUID(1, 0);
final UUID exchangeId = new UUID(2, 0);
-
+ /* These lines necessary to get queue creation to work because AMQQueueFactory is called directly rather than
+ queue creation being on vhost - yuck! */
+ SecurityManager securityManager = mock(SecurityManager.class);
+ when(_vhost.getSecurityManager()).thenReturn(securityManager);
+ when(securityManager.authoriseCreateQueue(anyBoolean(),anyBoolean(),anyBoolean(),anyBoolean(),anyBoolean(),
+ any(AMQShortString.class),anyString())).thenReturn(true);
+ VirtualHostConfiguration configuration = mock(VirtualHostConfiguration.class);
+ when(_vhost.getConfiguration()).thenReturn(configuration);
+ QueueConfiguration queueConfiguration = mock(QueueConfiguration.class);
+ when(configuration.getQueueConfiguration(anyString())).thenReturn(queueConfiguration);
+ LogActor logActor = mock(LogActor.class);
+ CurrentActor.set(logActor);
+ RootMessageLogger rootLogger = mock(RootMessageLogger.class);
+ when(logActor.getRootMessageLogger()).thenReturn(rootLogger);
+ /* end of queue creation mock hackery */
final Exchange customExchange = mock(Exchange.class);