aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/TopicEndpoint.java2
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/NoopTopicSinkFactory.java14
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSinkFactory.java2
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java2
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusConsumer.java6
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java2
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/http/client/internal/JerseyClient.java3
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyJerseyServer.java10
-rw-r--r--policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyServletServer.java39
9 files changed, 42 insertions, 38 deletions
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/TopicEndpoint.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/TopicEndpoint.java
index 09ee9a4e..fc7db6f7 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/TopicEndpoint.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/TopicEndpoint.java
@@ -570,7 +570,6 @@ class ProxyTopicEndpointManager implements TopicEndpoint {
return this.getUebTopicSource(topicName);
case DMAAP:
return this.getDmaapTopicSource(topicName);
- case REST:
default:
throw new UnsupportedOperationException("Unsupported " + commType.name());
}
@@ -596,7 +595,6 @@ class ProxyTopicEndpointManager implements TopicEndpoint {
return this.getDmaapTopicSink(topicName);
case NOOP:
return this.getNoopTopicSink(topicName);
- case REST:
default:
throw new UnsupportedOperationException("Unsupported " + commType.name());
}
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/NoopTopicSinkFactory.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/NoopTopicSinkFactory.java
index 53315391..1958da06 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/NoopTopicSinkFactory.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/NoopTopicSinkFactory.java
@@ -115,7 +115,7 @@ class IndexedNoopTopicSinkFactory implements NoopTopicSinkFactory {
final List<String> sinkTopicList =
new ArrayList<>(Arrays.asList(sinkTopics.split("\\s*,\\s*")));
- final List<NoopTopicSink> newSinks = new ArrayList<NoopTopicSink>();
+ final List<NoopTopicSink> newSinks = new ArrayList<>();
synchronized (this) {
for (final String topic : sinkTopicList) {
if (this.noopTopicSinks.containsKey(topic)) {
@@ -148,12 +148,14 @@ class IndexedNoopTopicSinkFactory implements NoopTopicSinkFactory {
@Override
public NoopTopicSink build(List<String> servers, String topic, boolean managed) {
- if (servers == null) {
- servers = new ArrayList<>();
+
+ List<String> noopSinkServers = servers;
+ if (noopSinkServers == null) {
+ noopSinkServers = new ArrayList<>();
}
- if (servers.isEmpty()) {
- servers.add("noop");
+ if (noopSinkServers.isEmpty()) {
+ noopSinkServers.add("noop");
}
if (topic == null || topic.isEmpty()) {
@@ -165,7 +167,7 @@ class IndexedNoopTopicSinkFactory implements NoopTopicSinkFactory {
return this.noopTopicSinks.get(topic);
}
- final NoopTopicSink sink = new NoopTopicSink(servers, topic);
+ final NoopTopicSink sink = new NoopTopicSink(noopSinkServers, topic);
if (managed)
this.noopTopicSinks.put(topic, sink);
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSinkFactory.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSinkFactory.java
index 2a20c317..fc4229c3 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSinkFactory.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSinkFactory.java
@@ -125,7 +125,7 @@ class IndexedUebTopicSinkFactory implements UebTopicSinkFactory {
* UEB Topic Name Index
*/
protected HashMap<String, UebTopicSink> uebTopicSinks =
- new HashMap<String, UebTopicSink>();
+ new HashMap<>();
@Override
public UebTopicSink build(List<String> servers,
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java
index 6f3bd350..d2aa6710 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/UebTopicSourceFactory.java
@@ -207,7 +207,7 @@ class IndexedUebTopicSourceFactory implements UebTopicSourceFactory {
String readTopics = properties.getProperty(PolicyProperties.PROPERTY_UEB_SOURCE_TOPICS);
if (readTopics == null || readTopics.isEmpty()) {
logger.info("{}: no topic for UEB Source", this);
- return new ArrayList<UebTopicSource>();
+ return new ArrayList<>();
}
List<String> readTopicList = new ArrayList<>(Arrays.asList(readTopics.split("\\s*,\\s*")));
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusConsumer.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusConsumer.java
index 8171c35d..06503304 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusConsumer.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusConsumer.java
@@ -237,7 +237,7 @@ public interface BusConsumer {
logger.debug("DMaaP consumer received {} : {}" + response.getResponseCode(),
response.getResponseMessage());
- if (response.getResponseCode() == null || !response.getResponseCode().equals("200")) {
+ if (response.getResponseCode() == null || !"200".equals(response.getResponseCode())) {
logger.error("DMaaP consumer received: {} : {}", response.getResponseCode(),
response.getResponseMessage());
@@ -450,8 +450,8 @@ public interface BusConsumer {
props.setProperty("contenttype", "application/json");
if (additionalProps != null) {
- for (final String key : additionalProps.keySet())
- props.put(key, additionalProps.get(key));
+ for (Map.Entry<String, String> entry : additionalProps.entrySet())
+ props.put(entry.getKey(), entry.getValue());
}
MRClientFactory.prop = props;
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java
index 10bc8325..df2088c1 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/event/comm/bus/internal/BusPublisher.java
@@ -302,8 +302,6 @@ public interface BusPublisher {
/**
* MR based Publisher
*/
- protected MRSimplerBatchPublisher publisher;
-
public DmaapAafPublisherWrapper(List<String> servers, String topic,
String aafLogin,
String aafPassword, boolean useHttps) {
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/http/client/internal/JerseyClient.java b/policy-endpoints/src/main/java/org/onap/policy/drools/http/client/internal/JerseyClient.java
index 5dd97363..9b18cae0 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/http/client/internal/JerseyClient.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/http/client/internal/JerseyClient.java
@@ -91,7 +91,7 @@ public class JerseyClient implements HttpClient {
this.password = password;
this.selfSignedCerts = selfSignedCerts;
- StringBuffer tmpBaseUrl = new StringBuffer();
+ StringBuilder tmpBaseUrl = new StringBuilder();
if (this.https) {
tmpBaseUrl.append("https://");
ClientBuilder clientBuilder;
@@ -195,6 +195,7 @@ public class JerseyClient implements HttpClient {
return hostname;
}
+ @Override
public int getPort() {
return port;
}
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyJerseyServer.java b/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyJerseyServer.java
index 8d66807d..f882c927 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyJerseyServer.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyJerseyServer.java
@@ -93,7 +93,7 @@ public class JettyJerseyServer extends JettyServletServer {
/**
* Container for servlets
*/
- protected HashMap<String, ServletHolder> servlets = new HashMap<String, ServletHolder>();
+ protected HashMap<String, ServletHolder> servlets = new HashMap<>();
/**
* Swagger ID
@@ -171,14 +171,14 @@ public class JettyJerseyServer extends JettyServletServer {
@Override
public synchronized void addServletPackage(String servletPath, String restPackage) {
-
+ String servPath = servletPath;
if (restPackage == null || restPackage.isEmpty())
throw new IllegalArgumentException("No discoverable REST package provided");
- if (servletPath == null || servletPath.isEmpty())
- servletPath = "/*";
+ if (servPath == null || servPath.isEmpty())
+ servPath = "/*";
- ServletHolder jerseyServlet = this.getServlet(servletPath);
+ ServletHolder jerseyServlet = this.getServlet(servPath);
String initClasses =
jerseyServlet.getInitParameter(JERSEY_INIT_CLASSNAMES_PARAM_NAME);
diff --git a/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyServletServer.java b/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyServletServer.java
index e0a46173..08c62445 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyServletServer.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/drools/http/server/internal/JettyServletServer.java
@@ -111,37 +111,40 @@ public abstract class JettyServletServer implements HttpServletServer, Runnable
* @throws IllegalArgumentException if invalid parameters are passed in
*/
public JettyServletServer(String name, String host, int port, String contextPath) {
-
- if (name == null || name.isEmpty())
- name = "http-" + port;
+ String srvName = name;
+ String srvHost = host;
+ String ctxtPath = contextPath;
+
+ if (srvName == null || srvName.isEmpty())
+ srvName = "http-" + port;
if (port <= 0 && port >= 65535)
throw new IllegalArgumentException("Invalid Port provided: " + port);
- if (host == null || host.isEmpty())
- host = "localhost";
+ if (srvHost == null || srvHost.isEmpty())
+ srvHost = "localhost";
- if (contextPath == null || contextPath.isEmpty())
- contextPath = "/";
+ if (ctxtPath == null || ctxtPath.isEmpty())
+ ctxtPath = "/";
- this.name = name;
+ this.name = srvName;
- this.host = host;
+ this.host = srvHost;
this.port = port;
- this.contextPath = contextPath;
+ this.contextPath = ctxtPath;
this.context = new ServletContextHandler(ServletContextHandler.SESSIONS);
- this.context.setContextPath(contextPath);
+ this.context.setContextPath(ctxtPath);
this.jettyServer = new Server();
this.jettyServer.setRequestLog(new Slf4jRequestLog());
this.connector = new ServerConnector(this.jettyServer);
- this.connector.setName(name);
+ this.connector.setName(srvName);
this.connector.setReuseAddress(true);
this.connector.setPort(port);
- this.connector.setHost(host);
+ this.connector.setHost(srvHost);
this.jettyServer.addConnector(this.connector);
this.jettyServer.setHandler(context);
@@ -149,11 +152,13 @@ public abstract class JettyServletServer implements HttpServletServer, Runnable
@Override
public void setBasicAuthentication(String user, String password, String servletPath) {
- if (user == null || user.isEmpty() || password == null || password.isEmpty())
+ String srvltPath = servletPath;
+
+ if (user == null || user.isEmpty() || password == null || password.isEmpty())
throw new IllegalArgumentException("Missing user and/or password");
- if (servletPath == null || servletPath.isEmpty())
- servletPath = "/*";
+ if (srvltPath == null || srvltPath.isEmpty())
+ srvltPath = "/*";
HashLoginService hashLoginService = new HashLoginService();
hashLoginService.putUser(user,
@@ -168,7 +173,7 @@ public abstract class JettyServletServer implements HttpServletServer, Runnable
ConstraintMapping constraintMapping = new ConstraintMapping();
constraintMapping.setConstraint(constraint);
- constraintMapping.setPathSpec(servletPath);
+ constraintMapping.setPathSpec(srvltPath);
ConstraintSecurityHandler securityHandler = new ConstraintSecurityHandler();
securityHandler.setAuthenticator(new BasicAuthenticator());