blob: 41e4e43a94510f932cf9577da55aee20dc38fe72 (
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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
/*-
* ============LICENSE_START=======================================================
* ONAP Policy API
* ================================================================================
* Copyright (C) 2018 Samsung Electronics Co., Ltd. All rights reserved.
* Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* 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.api.main.startstop;
import org.onap.policy.api.main.exception.PolicyApiException;
import org.onap.policy.api.main.parameters.ApiParameterGroup;
import org.onap.policy.api.main.rest.ApiRestController;
import org.onap.policy.api.main.rest.LegacyApiRestController;
import org.onap.policy.api.main.rest.aaf.AafApiFilter;
import org.onap.policy.common.endpoints.http.server.RestServer;
import org.onap.policy.common.parameters.ParameterService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* This class wraps a distributor so that it can be activated as a complete service together with all its api
* and forwarding handlers.
*/
public class ApiActivator {
private static final Logger LOGGER = LoggerFactory.getLogger(ApiActivator.class);
private final ApiParameterGroup apiParameterGroup;
private static boolean alive = false;
private RestServer restServer;
/**
* Instantiate the activator for policy api as a complete service.
*
* @param apiParameterGroup the parameters for the api service
*/
public ApiActivator(final ApiParameterGroup apiParameterGroup) {
this.apiParameterGroup = apiParameterGroup;
}
/**
* Initialize api as a complete service.
*
* @throws PolicyApiException on errors in initializing the service
*/
public void initialize() throws PolicyApiException {
LOGGER.debug("Policy api starting as a service . . .");
startApiRestServer();
registerToParameterService(apiParameterGroup);
ApiActivator.setAlive(true);
LOGGER.debug("Policy api started as a service");
}
/**
* Starts the api rest server using configuration parameters.
*
* @throws PolicyApiException if server start fails
*/
private void startApiRestServer() throws PolicyApiException {
apiParameterGroup.getRestServerParameters().setName(apiParameterGroup.getName());
restServer = new RestServer(apiParameterGroup.getRestServerParameters(), AafApiFilter.class,
LegacyApiRestController.class,
ApiRestController.class);
if (!restServer.start()) {
throw new PolicyApiException(
"Failed to start api rest server. Check log for more details...");
}
}
/**
* Terminate policy api.
*
* @throws PolicyApiException on termination errors
*/
public void terminate() throws PolicyApiException {
try {
deregisterToParameterService(apiParameterGroup);
ApiActivator.setAlive(false);
// Stop the api rest server
restServer.stop();
} catch (final Exception exp) {
throw new PolicyApiException("Policy api service termination failed", exp);
}
}
/**
* Get the parameters used by the activator.
*
* @return the parameters of the activator
*/
public ApiParameterGroup getParameterGroup() {
return apiParameterGroup;
}
/**
* Method to register the parameters to Common Parameter Service.
*
* @param apiParameterGroup the api parameter group
*/
public void registerToParameterService(final ApiParameterGroup apiParameterGroup) {
ParameterService.register(apiParameterGroup, true);
}
/**
* Method to deregister the parameters from Common Parameter Service.
*
* @param apiParameterGroup the api parameter group
*/
public void deregisterToParameterService(final ApiParameterGroup apiParameterGroup) {
ParameterService.deregister(apiParameterGroup.getName());
}
/**
* Returns the alive status of api service.
*
* @return the alive
*/
public static boolean isAlive() {
return alive;
}
/**
* Change the alive status of api service.
*
* @param status the status
*/
public static void setAlive(final boolean status) {
alive = status;
}
}
|
