1 files changed, 19 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/QueueConfiguration.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/QueueConfiguration.java
index 90d6caec99..e6c5dee90d 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/QueueConfiguration.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/configuration/QueueConfiguration.java
@@ -21,8 +21,10 @@
 package org.apache.qpid.server.configuration;
 
 import java.util.List;
+import java.io.File;
 
 import org.apache.commons.configuration.Configuration;
+import org.apache.qpid.server.registry.ApplicationRegistry;
 
 public class QueueConfiguration
 {
@@ -31,13 +33,20 @@ public class QueueConfiguration
     
     private Configuration _config;
     private String _name;
+    private VirtualHostConfiguration _virtualHostConfiguration;
 
-    public QueueConfiguration(String name, Configuration config)
+    public QueueConfiguration(String name, Configuration config, VirtualHostConfiguration virtualHostConfiguration)
     {
+        _virtualHostConfiguration = virtualHostConfiguration;
         _config = config;
         _name = name;
     }
 
+    public VirtualHostConfiguration getVirtualHostConfiguration()
+    {
+        return _virtualHostConfiguration;
+    }
+
     public boolean getDurable()
     {
         return _config.getBoolean("durable" ,false);
@@ -103,4 +112,13 @@ public class QueueConfiguration
         return _config.getLong("minimumAlertRepeatGap", 0);
     }
 
+    public long getMemoryUsageMaximum()
+    {
+        return _config.getLong("maximumMemoryUsage", 100 * 1024 * 1024); //100Meg
+    }
+
+    public long getMemoryUsageMinimum()
+    {
+        return _config.getLong("minimumMemoryUsage", 0);
+    }
 }