diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2013-08-16 10:23:51 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2013-08-16 10:23:51 +0000 |
| commit | 2bc8d87a2fe3e8b1140b7c3499a85527aa3a63d7 (patch) | |
| tree | 6b68739a6f60fb1ccb33c0bc82bb114905836e8c /qpid/java | |
| parent | e80a585caa90715069cd66e19ce40f0859086149 (diff) | |
| download | qpid-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.java | 32 |
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); |
