commit 67ad35414d2162a9554c0b026647cdb3908a0e9a
author Alex Rudyy <orudyy@apache.org> Wed Jul 24 10:18:30 2019 +0100
committer Alex Rudyy <orudyy@apache.org> Fri Jul 26 15:58:32 2019 +0100
tree dca9a4c7c7e1a6f13f64f96aeeb0add3f5b2f289
parent 53bca71335e622fbc92a04dc0f68a8a6bad45120

QPID-8349: Extend broker admin interface with attributes to identify support of operations to put messages on a queue and queue deletion

systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java

diff --git a/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java b/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java
index c5a076c..9f8ed5e 100644
--- a/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java
+++ b/systests/qpid-systests-spawn-admin/src/main/java/org/apache/qpid/systests/admin/SpawnBrokerAdmin.java
@@ -282,6 +282,18 @@
     }
 
     @Override
+    public boolean isPutMessageOnQueueSupported()
+    {
+        return true;
+    }
+
+    @Override
+    public boolean isDeleteQueueSupported()
+    {
+        return true;
+    }
+
+    @Override
     public String getValidUsername()
     {
         return "admin";

systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java

diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java
index 5c4f974..b8acf34 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/BrokerAdmin.java
@@ -53,6 +53,8 @@
     boolean isWebSocketSupported();
     boolean isQueueDepthSupported();
     boolean isManagementSupported();
+    boolean isPutMessageOnQueueSupported();
+    boolean isDeleteQueueSupported();
 
     String getValidUsername();
     String getValidPassword();

systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java

diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java
index 1b74bbe..9ba6aed 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/EmbeddedBrokerPerClassAdminImpl.java
@@ -374,6 +374,18 @@
     }
 
     @Override
+    public boolean isPutMessageOnQueueSupported()
+    {
+        return true;
+    }
+
+    @Override
+    public boolean isDeleteQueueSupported()
+    {
+        return true;
+    }
+
+    @Override
     public String getValidUsername()
     {
         return "guest";

systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java

diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java
index a54df16..db5d44d 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/ExternalQpidBrokerAdminImpl.java
@@ -173,4 +173,17 @@
     {
         return EXTERNAL_BROKER;
     }
+
+    @Override
+    public boolean isPutMessageOnQueueSupported()
+    {
+        return false;
+    }
+
+    @Override
+    public boolean isDeleteQueueSupported()
+    {
+        return false;
+    }
+
 }

systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java

diff --git a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java
index f27df58..6674e3e 100644
--- a/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java
+++ b/systests/systests-utils/src/main/java/org/apache/qpid/tests/utils/LoggingBrokerAdminDecorator.java
@@ -157,6 +157,18 @@
     }
 
     @Override
+    public boolean isPutMessageOnQueueSupported()
+    {
+        return _delegate.isPutMessageOnQueueSupported();
+    }
+
+    @Override
+    public boolean isDeleteQueueSupported()
+    {
+        return _delegate.isDeleteQueueSupported();
+    }
+
+    @Override
     public String getValidUsername()
     {
         return _delegate.getValidUsername();