JUnit 5 Annotations Used:
+ *Options in a JUnit 5 Suite:
+ *Example Usage:
+ *
+ * {@code
+ * @Suite
+ * @SelectClasses({IntegrationTest.class}) // List your test classes here
+ * @SelectPackages("org.bitrepository.protocol") // List your test packages here
+ * @IncludeTags("integration") // List your include tags here
+ * @ExcludeTags("slow") // List your exclude tags here
+ * @ExtendWith(GlobalSuiteExtension.class)
+ * public class BitrepositoryTestSuite {
+ * // No need for methods here; this just groups and extends
+ * }
+ * }
+ *
+ */
+@Suite
+@SelectClasses({IntegrationTest.class}) // List your test classes here
+@ExtendWith(GlobalSuiteExtension.class)
+public class BitrepositoryTestSuite {
+ // No need for methods here; this just groups and extends
+}
+
diff --git a/bitrepository-core/src/test/java/org/bitrepository/protocol/GlobalSuiteExtension.java b/bitrepository-core/src/test/java/org/bitrepository/protocol/GlobalSuiteExtension.java
new file mode 100644
index 000000000..886419ac8
--- /dev/null
+++ b/bitrepository-core/src/test/java/org/bitrepository/protocol/GlobalSuiteExtension.java
@@ -0,0 +1,208 @@
+package org.bitrepository.protocol;
+
+import org.bitrepository.common.settings.Settings;
+import org.bitrepository.common.settings.TestSettingsProvider;
+import org.bitrepository.common.utils.SettingsUtils;
+import org.bitrepository.common.utils.TestFileHelper;
+import org.bitrepository.protocol.bus.LocalActiveMQBroker;
+import org.bitrepository.protocol.bus.MessageReceiver;
+import org.bitrepository.protocol.fileexchange.HttpServerConfiguration;
+import org.bitrepository.protocol.http.EmbeddedHttpServer;
+import org.bitrepository.protocol.messagebus.MessageBus;
+import org.bitrepository.protocol.messagebus.MessageBusManager;
+import org.bitrepository.protocol.messagebus.SimpleMessageBus;
+import org.bitrepository.protocol.security.DummySecurityManager;
+import org.bitrepository.protocol.security.SecurityManager;
+import org.jaccept.TestEventManager;
+import org.junit.jupiter.api.extension.*;
+
+import javax.jms.JMSException;
+import java.net.MalformedURLException;
+import java.net.URL;
+
+public class GlobalSuiteExtension implements BeforeAllCallback, AfterAllCallback {
+
+ private static boolean initialized = false;
+ protected static TestEventManager testEventManager = TestEventManager.getInstance();
+ public static LocalActiveMQBroker broker;
+ public static EmbeddedHttpServer server;
+ public static HttpServerConfiguration httpServerConfiguration;
+ public static MessageBus messageBus;
+ private MessageReceiverManager receiverManager;
+ protected static String alarmDestinationID;
+ protected static MessageReceiver alarmReceiver;
+ protected static SecurityManager securityManager;
+ protected static Settings settingsForCUT;
+ protected static Settings settingsForTestClient;
+ protected static String collectionID;
+ protected String NON_DEFAULT_FILE_ID;
+ protected static String DEFAULT_FILE_ID;
+ protected static URL DEFAULT_FILE_URL;
+ protected static String DEFAULT_DOWNLOAD_FILE_ADDRESS;
+ protected static String DEFAULT_UPLOAD_FILE_ADDRESS;
+ protected String DEFAULT_AUDIT_INFORMATION;
+ protected String testMethodName;
+
+ @Override
+ public void beforeAll(ExtensionContext context) {
+ if (!initialized) {
+ initialized = true;
+ settingsForCUT = loadSettings(getComponentID());
+ settingsForTestClient = loadSettings("TestSuiteInitialiser");
+ makeUserSpecificSettings(settingsForCUT);
+ makeUserSpecificSettings(settingsForTestClient);
+ httpServerConfiguration = new HttpServerConfiguration(settingsForTestClient.getReferenceSettings().getFileExchangeSettings());
+ collectionID = settingsForTestClient.getCollections().get(0).getID();
+
+ securityManager = createSecurityManager();
+ DEFAULT_FILE_ID = "DefaultFile";
+ try {
+ DEFAULT_FILE_URL = httpServerConfiguration.getURL(TestFileHelper.DEFAULT_FILE_ID);
+ DEFAULT_DOWNLOAD_FILE_ADDRESS = DEFAULT_FILE_URL.toExternalForm();
+ DEFAULT_UPLOAD_FILE_ADDRESS = DEFAULT_FILE_URL.toExternalForm() + "-" + DEFAULT_FILE_ID;
+ } catch (MalformedURLException e) {
+ throw new RuntimeException("Never happens", e);
+ }
+ }
+ }
+
+ @Override
+ public void afterAll(ExtensionContext context) {
+ if (initialized) {
+ teardownMessageBus();
+ teardownHttpServer();
+ }
+ }
+
+ /**
+ * May be extended by subclasses needing to have their receivers managed. Remember to still call
+ * super.registerReceivers() when overriding
+ */
+ protected void registerMessageReceivers() {
+ alarmReceiver = new MessageReceiver(settingsForCUT.getAlarmDestination(), testEventManager);
+ addReceiver(alarmReceiver);
+ }
+
+ protected void addReceiver(MessageReceiver receiver) {
+ receiverManager.addReceiver(receiver);
+ }
+ protected void initializeCUT() {}
+
+ /**
+ * Purges all messages from the receivers.
+ */
+ protected void clearReceivers() {
+ receiverManager.clearMessagesInReceivers();
+ }
+
+ /**
+ * May be overridden by specific tests wishing to do stuff. Remember to call super if this is overridden.
+ */
+ protected void shutdownCUT() {}
+
+ /**
+ * Initializes the settings. Will postfix the alarm and collection topics with '-${user.name}
+ */
+ protected void setupSettings() {
+ settingsForCUT = loadSettings(getComponentID());
+ makeUserSpecificSettings(settingsForCUT);
+ SettingsUtils.initialize(settingsForCUT);
+
+ alarmDestinationID = settingsForCUT.getRepositorySettings().getProtocolSettings().getAlarmDestination();
+
+ settingsForTestClient = loadSettings(testMethodName);
+ makeUserSpecificSettings(settingsForTestClient);
+ }
+
+
+ protected Settings loadSettings(String componentID) {
+ return TestSettingsProvider.reloadSettings(componentID);
+ }
+
+ private void makeUserSpecificSettings(Settings settings) {
+ settings.getRepositorySettings().getProtocolSettings()
+ .setCollectionDestination(settings.getCollectionDestination() + getTopicPostfix());
+ settings.getRepositorySettings().getProtocolSettings().setAlarmDestination(settings.getAlarmDestination() + getTopicPostfix());
+ }
+
+ /**
+ * Indicated whether an embedded active MQ should be started and used
+ */
+ public boolean useEmbeddedMessageBus() {
+ return System.getProperty("useEmbeddedMessageBus", "true").equals("true");
+ }
+
+ /**
+ * Indicated whether an embedded http server should be started and used
+ */
+ public boolean useEmbeddedHttpServer() {
+ return System.getProperty("useEmbeddedHttpServer", "false").equals("true");
+ }
+
+ /**
+ * Hooks up the message bus.
+ */
+ protected void setupMessageBus() {
+ if (useEmbeddedMessageBus()) {
+ if (messageBus == null) {
+ messageBus = new SimpleMessageBus();
+ }
+ }
+ }
+
+ /**
+ * Shutdown the message bus.
+ */
+ private void teardownMessageBus() {
+ MessageBusManager.clear();
+ if (messageBus != null) {
+ try {
+ messageBus.close();
+ messageBus = null;
+ } catch (JMSException e) {
+ throw new RuntimeException(e);
+ }
+ }
+
+ if (broker != null) {
+ try {
+ broker.stop();
+ broker = null;
+ } catch (Exception e) {
+ // No reason to pollute the test output with this
+ }
+ }
+ }
+
+ /**
+ * Shutdown the embedded http server if any.
+ */
+ protected void teardownHttpServer() {
+ if (useEmbeddedHttpServer()) {
+ server.stop();
+ }
+ }
+
+ /**
+ * Returns the postfix string to use when accessing user specific topics, which is the mechanism we use in the
+ * bit repository tests.
+ *
+ * @return The string to postfix all topix names with.
+ */
+ protected String getTopicPostfix() {
+ return "-" + System.getProperty("user.name");
+ }
+
+ protected String getComponentID() {
+ return getClass().getSimpleName();
+ }
+
+ protected String createDate() {
+ return Long.toString(System.currentTimeMillis());
+ }
+
+ protected SecurityManager createSecurityManager() {
+ return new DummySecurityManager();
+ }
+
+}
\ No newline at end of file
diff --git a/bitrepository-core/src/test/java/org/bitrepository/protocol/IntegrationTest.java b/bitrepository-core/src/test/java/org/bitrepository/protocol/IntegrationTest.java
index ece1da863..2d9c82ff4 100644
--- a/bitrepository-core/src/test/java/org/bitrepository/protocol/IntegrationTest.java
+++ b/bitrepository-core/src/test/java/org/bitrepository/protocol/IntegrationTest.java
@@ -81,6 +81,10 @@ public abstract class IntegrationTest extends ExtendedTestCase {
@BeforeSuite(alwaysRun = true)
public void initializeSuite(ITestContext testContext) {
+ //
+ }
+
+ private void initializationMethod() {
settingsForCUT = loadSettings(getComponentID());
settingsForTestClient = loadSettings("TestSuiteInitialiser");
makeUserSpecificSettings(settingsForCUT);
@@ -114,6 +118,7 @@ protected void addReceiver(MessageReceiver receiver) {
@BeforeClass(alwaysRun = true)
public void initMessagebus() {
+ initializationMethod();
setupMessageBus();
}
diff --git a/bitrepository-core/src/test/java/org/bitrepository/protocol/bus/ActiveMQMessageBusTest.java b/bitrepository-core/src/test/java/org/bitrepository/protocol/bus/ActiveMQMessageBusTest.java
index d5b9bf884..6b284a415 100644
--- a/bitrepository-core/src/test/java/org/bitrepository/protocol/bus/ActiveMQMessageBusTest.java
+++ b/bitrepository-core/src/test/java/org/bitrepository/protocol/bus/ActiveMQMessageBusTest.java
@@ -8,12 +8,12 @@
* it under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation, either version 2.1 of the
* License, or (at your option) any later version.
- *
+ *
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Lesser Public License for more details.
- *
+ *
* You should have received a copy of the GNU General Lesser Public
* License along with this program. If not, see
*