From acdb57af871cbfef3a768b2dd765246063129d5d Mon Sep 17 00:00:00 2001
From: Robert Godfrey <rgodfrey@apache.org>
Date: Sat, 8 Nov 2014 12:56:12 +0000
Subject: QPID-6221 : [Java Broker] Detect low disk space conditions and
 enforce flow control

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1637558 13f79535-47bb-0310-9956-ffa450edef68
---
 .../qpid/server/store/jdbc/GenericJDBCConfigurationStore.java      | 7 +++++++
 .../org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java | 7 +++++++
 2 files changed, 14 insertions(+)

(limited to 'qpid/java/broker-plugins/jdbc-store/src')

diff --git a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java
index 13d5c54ee4..3c3b1da880 100644
--- a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java
+++ b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCConfigurationStore.java
@@ -19,6 +19,7 @@
 package org.apache.qpid.server.store.jdbc;
 
 
+import java.io.File;
 import java.nio.charset.Charset;
 import java.security.PrivilegedAction;
 import java.sql.Blob;
@@ -286,6 +287,12 @@ public class GenericJDBCConfigurationStore extends AbstractJDBCConfigurationStor
             return GenericJDBCConfigurationStore.this._connectionURL;
         }
 
+        @Override
+        public File getStoreLocationAsFile()
+        {
+            return null;
+        }
+
         @Override
         protected Logger getLogger()
         {
diff --git a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java
index 59e165acc2..a75ca4d685 100644
--- a/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java
+++ b/qpid/java/broker-plugins/jdbc-store/src/main/java/org/apache/qpid/server/store/jdbc/GenericJDBCMessageStore.java
@@ -21,6 +21,7 @@
 package org.apache.qpid.server.store.jdbc;
 
 
+import java.io.File;
 import java.security.PrivilegedAction;
 import java.sql.Blob;
 import java.sql.Connection;
@@ -177,6 +178,12 @@ public class GenericJDBCMessageStore extends GenericAbstractJDBCMessageStore
         return _connectionURL;
     }
 
+    @Override
+    public File getStoreLocationAsFile()
+    {
+        return null;
+    }
+
     protected String getPlainTextPassword(final JDBCSettings settings)
     {
         return Subject.doAs(SecurityManager.getSubjectWithAddedSystemRights(), new PrivilegedAction<String>()
-- 
cgit v1.2.1