blob: 02d913de4eadfa30196da07196fff89928b8405c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
/*-
* ============LICENSE_START=======================================================
* Copyright (C) 2022-2023 Nordix Foundation.
* ================================================================================
* Licensed 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.
*
* SPDX-License-Identifier: Apache-2.0
* ============LICENSE_END=========================================================
*/
package org.onap.policy.apex.testsuites.integration.uservice.adapt.jms;
import static org.awaitility.Awaitility.await;
import java.util.concurrent.TimeUnit;
import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl;
import org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class JmsServerRunner implements Runnable {
private static final Logger LOGGER = LoggerFactory.getLogger(JmsServerRunner.class);
// Embedded JMS server
private EmbeddedActiveMQ embedded;
// Thread to run the JMS server in
private Thread jmsServerRunnerThread;
// Config fields
private final String serverName;
private final String serverUri;
/**
* Create the JMS Server.
*
* @param serverName Name of the server
* @param serverUri URI for the server
* @throws Exception on errors
*/
public JmsServerRunner(String serverName, String serverUri) throws Exception {
this.serverName = serverName;
this.serverUri = serverUri;
ConfigurationImpl config = new ConfigurationImpl();
config.addAcceptorConfiguration(serverName, serverUri);
config.setSecurityEnabled(false);
config.setJournalDirectory("target/artemisActiveMq/data/journal");
config.setBindingsDirectory("target/artemisActiveMq/data/bindings");
config.setLargeMessagesDirectory("target/artemisActiveMq/data/largemessages");
config.setPagingDirectory("target/artemisActiveMq/data/paging");
embedded = new EmbeddedActiveMQ();
embedded.setConfiguration(config);
LOGGER.debug("starting JMS Server " + serverName + " on URI " + serverUri + " . . .");
jmsServerRunnerThread = new Thread(this);
jmsServerRunnerThread.start();
LOGGER.debug("requested start on JMS Server " + serverName + " on URI " + serverUri);
}
@Override
public void run() {
try {
LOGGER.debug("starting JMS Server thread " + serverName + " on URI " + serverUri + " . . .");
embedded.start();
await().atMost(30, TimeUnit.SECONDS).until(() -> embedded.getActiveMQServer().isActive());
LOGGER.debug("started JMS Server thread " + serverName + " on URI " + serverUri);
} catch (Exception e) {
LOGGER.warn("failed to start JMS Server thread " + serverName + " on URI " + serverUri, e);
}
}
/**
* Stop the JMS server.
*
* @throws Exception on stop errors
*/
public void stop() throws Exception {
LOGGER.debug("stopping JMS Server " + serverName + " on URI " + serverUri + " . . .");
if (!embedded.getActiveMQServer().isActive()) {
LOGGER.debug("JMS Server " + serverName + " already stopped on URI " + serverUri + " . . .");
return;
}
embedded.stop();
LOGGER.debug("waiting on JMS Server " + serverName + " to stop on URI " + serverUri + " . . .");
await().atMost(30, TimeUnit.SECONDS)
.until(() -> !embedded.getActiveMQServer().isActive() && !jmsServerRunnerThread.isAlive());
LOGGER.debug("stopping JMS Server " + serverName + " on URI " + serverUri + " . . .");
}
}
|
