diff options
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java')
| -rw-r--r-- | qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java index 1138b465cd..1acf8a3c31 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java @@ -175,7 +175,8 @@ public class AMQQueueMBeanTest extends TestCase assertTrue(_queueMBean.getActiveConsumerCount() == 0); - InternalTestProtocolSession protocolSession = new InternalTestProtocolSession(); + InternalTestProtocolSession protocolSession = new InternalTestProtocolSession(_virtualHost); + AMQChannel channel = new AMQChannel(protocolSession, 1, _messageStore); protocolSession.addChannel(channel); @@ -372,7 +373,7 @@ public class AMQQueueMBeanTest extends TestCase null); _queueMBean = new AMQQueueMBean(_queue); - _protocolSession = new InternalTestProtocolSession(); + _protocolSession = new InternalTestProtocolSession(_virtualHost); } public void tearDown() |