| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| */ |
| |
| package org.apache.qpid.tests.utils; |
| |
| import java.lang.reflect.Method; |
| import java.net.InetSocketAddress; |
| |
| import com.google.common.util.concurrent.ListenableFuture; |
| |
| import org.apache.qpid.server.plugin.Pluggable; |
| |
| public interface BrokerAdmin extends Pluggable |
| { |
| String KIND_BROKER_J = "broker-j"; |
| String TEST_QUEUE_NAME = "testQueue"; |
| Long RESTART_TIMEOUT = Long.getLong("brokerAdmin.restart_timeout", 10000); |
| |
| void beforeTestClass(final Class testClass); |
| void beforeTestMethod(final Class testClass, final Method method); |
| void afterTestMethod(final Class testClass, final Method method); |
| void afterTestClass(final Class testClass); |
| |
| InetSocketAddress getBrokerAddress(PortType portType); |
| |
| void createQueue(String queueName); |
| void deleteQueue(String queueName); |
| void putMessageOnQueue(String queueName, String... messages); |
| int getQueueDepthMessages(String testQueueName); |
| |
| boolean supportsRestart(); |
| ListenableFuture<Void> restart(); |
| |
| boolean isAnonymousSupported(); |
| boolean isSASLSupported(); |
| boolean isSASLMechanismSupported(String mechanismName); |
| boolean isWebSocketSupported(); |
| boolean isQueueDepthSupported(); |
| boolean isManagementSupported(); |
| boolean isPutMessageOnQueueSupported(); |
| boolean isDeleteQueueSupported(); |
| |
| String getValidUsername(); |
| String getValidPassword(); |
| |
| String getKind(); |
| |
| default PortType getPreferredPortType() |
| { |
| return isAnonymousSupported() ? PortType.ANONYMOUS_AMQP : PortType.AMQP; |
| } |
| |
| enum PortType |
| { |
| ANONYMOUS_AMQP, |
| ANONYMOUS_AMQPWS, |
| AMQP, |
| HTTP |
| } |
| } |