package org.onap.dmaap.mr.tools;
import java.util.Properties;
+
+import org.onap.dmaap.mr.client.DmaapClientConst;
import org.onap.dmaap.mr.client.ProtocolType;
public class ValidatorUtil {
- private static final String ID = "id";
- private static final String AUTH_KEY = "authKey";
- private static final String AUTH_DATE = "authDate";
- private static final String PASSWORD = "password";
- private static final String USERNAME = "username";
- private static final String HOST = "host";
- private static final String DME2PREFERRED_ROUTER_FILE_PATH = "DME2preferredRouterFilePath";
- private static final String TOPIC = "topic";
- private static final String TRANSPORT_TYPE = "TransportType";
- private static final String MAX_BATCH_SIZE = "maxBatchSize";
- private static final String MAX_AGE_MS = "maxAgeMs";
- private static final String MESSAGE_SENT_THREAD_OCCURRENCE_OLD = "MessageSentThreadOccurance";
- private static final String MESSAGE_SENT_THREAD_OCCURRENCE = "MessageSentThreadOccurrence";
- private static final String GROUP = "group";
- private static final String SERVICE_NAME = "ServiceName";
- private static final String PARTNER = "Partner";
- private static final String ROUTE_OFFER = "routeOffer";
- private static final String PROTOCOL = "Protocol";
- private static final String METHOD_TYPE = "MethodType";
- private static final String CONTENT_TYPE = "contenttype";
- private static final String LATITUDE = "Latitude";
- private static final String LONGITUDE = "Longitude";
- private static final String AFT_ENVIRONMENT = "AFT_ENVIRONMENT";
- private static final String VERSION = "Version";
- private static final String ENVIRONMENT = "Environment";
- private static final String SUB_CONTEXT_PATH = "SubContextPath";
- private static final String SESSION_STICKINESS_REQUIRED = "sessionstickinessrequired";
-
public static final String IS_NEEDED = " is needed";
private ValidatorUtil() {
}
public static void validatePublisher(Properties props) {
- String transportType = props.getProperty(TRANSPORT_TYPE);
+ String transportType = props.getProperty(DmaapClientConst.TRANSPORT_TYPE);
if (ProtocolType.DME2.getValue().equalsIgnoreCase(transportType)) {
validateForDME2(props);
} else {
validateForNonDME2(props);
}
- String maxBatchSize = props.getProperty(MAX_BATCH_SIZE, "");
+ String maxBatchSize = props.getProperty(DmaapClientConst.MAX_BATCH_SIZE, "");
if (maxBatchSize.isEmpty()) {
- throw new IllegalArgumentException(MAX_BATCH_SIZE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.MAX_BATCH_SIZE + IS_NEEDED);
}
- String maxAgeMs = props.getProperty(MAX_AGE_MS, "");
+ String maxAgeMs = props.getProperty(DmaapClientConst.MAX_AGE_MS, "");
if (maxAgeMs.isEmpty()) {
- throw new IllegalArgumentException(MAX_AGE_MS + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.MAX_AGE_MS + IS_NEEDED);
}
- String messageSentThreadOccurrence = props.getProperty(MESSAGE_SENT_THREAD_OCCURRENCE);
+ String messageSentThreadOccurrence = props.getProperty(DmaapClientConst.MESSAGE_SENT_THREAD_OCCURRENCE);
if (messageSentThreadOccurrence == null || messageSentThreadOccurrence.isEmpty()) {
- messageSentThreadOccurrence = props.getProperty(MESSAGE_SENT_THREAD_OCCURRENCE_OLD);
+ messageSentThreadOccurrence = props.getProperty(DmaapClientConst.MESSAGE_SENT_THREAD_OCCURRENCE_OLD);
}
if (messageSentThreadOccurrence == null || messageSentThreadOccurrence.isEmpty()) {
- throw new IllegalArgumentException(MESSAGE_SENT_THREAD_OCCURRENCE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.MESSAGE_SENT_THREAD_OCCURRENCE + IS_NEEDED);
}
try {
Integer.parseInt(messageSentThreadOccurrence);
} catch (NumberFormatException e) {
- throw new IllegalArgumentException(MESSAGE_SENT_THREAD_OCCURRENCE + " must be an integer");
+ throw new IllegalArgumentException(DmaapClientConst.MESSAGE_SENT_THREAD_OCCURRENCE + " must be an integer");
}
}
public static void validateSubscriber(Properties props) {
- String transportType = props.getProperty(TRANSPORT_TYPE);
+ String transportType = props.getProperty(DmaapClientConst.TRANSPORT_TYPE);
if (ProtocolType.DME2.getValue().equalsIgnoreCase(transportType)) {
validateForDME2(props);
} else {
validateForNonDME2(props);
}
- String group = props.getProperty(GROUP, "");
+ String group = props.getProperty(DmaapClientConst.GROUP, "");
if (group.isEmpty()) {
- throw new IllegalArgumentException(GROUP + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.GROUP + IS_NEEDED);
}
- String id = props.getProperty(ID, "");
+ String id = props.getProperty(DmaapClientConst.ID, "");
if (id.isEmpty()) {
- throw new IllegalArgumentException("Consumer (" + ID + ")" + IS_NEEDED);
+ throw new IllegalArgumentException("Consumer (" + DmaapClientConst.ID + ")" + IS_NEEDED);
}
}
private static void validateForDME2(Properties props) {
- String serviceName = props.getProperty(SERVICE_NAME, "");
+ String serviceName = props.getProperty(DmaapClientConst.SERVICE_NAME, "");
if (serviceName.isEmpty()) {
- throw new IllegalArgumentException(SERVICE_NAME + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.SERVICE_NAME + IS_NEEDED);
}
- String topic = props.getProperty(TOPIC, "");
+ String topic = props.getProperty(DmaapClientConst.TOPIC, "");
if (topic.isEmpty()) {
- throw new IllegalArgumentException(TOPIC + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.TOPIC + IS_NEEDED);
}
- String username = props.getProperty(USERNAME, "");
+ String username = props.getProperty(DmaapClientConst.USERNAME, "");
if (username.isEmpty()) {
- throw new IllegalArgumentException(USERNAME + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.USERNAME + IS_NEEDED);
}
- String password = props.getProperty(PASSWORD, "");
+ String password = props.getProperty(DmaapClientConst.PASSWORD, "");
if (password.isEmpty()) {
- throw new IllegalArgumentException(PASSWORD + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.PASSWORD + IS_NEEDED);
}
- String dme2preferredRouterFilePath = props.getProperty(DME2PREFERRED_ROUTER_FILE_PATH, "");
+ String dme2preferredRouterFilePath = props.getProperty(DmaapClientConst.DME2PREFERRED_ROUTER_FILE_PATH, "");
if (dme2preferredRouterFilePath.isEmpty()) {
- throw new IllegalArgumentException(DME2PREFERRED_ROUTER_FILE_PATH + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.DME2PREFERRED_ROUTER_FILE_PATH + IS_NEEDED);
}
- String partner = props.getProperty(PARTNER, "");
- String routeOffer = props.getProperty(ROUTE_OFFER, "");
+ String partner = props.getProperty(DmaapClientConst.PARTNER, "");
+ String routeOffer = props.getProperty(DmaapClientConst.ROUTE_OFFER, "");
if (partner.isEmpty() && routeOffer.isEmpty()) {
- throw new IllegalArgumentException(PARTNER + " or " + ROUTE_OFFER + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.PARTNER + " or " + DmaapClientConst.ROUTE_OFFER + IS_NEEDED);
}
- String protocol = props.getProperty(PROTOCOL, "");
+ String protocol = props.getProperty(DmaapClientConst.PROTOCOL, "");
if (protocol.isEmpty()) {
- throw new IllegalArgumentException(PROTOCOL + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.PROTOCOL + IS_NEEDED);
}
- String methodType = props.getProperty(METHOD_TYPE, "");
+ String methodType = props.getProperty(DmaapClientConst.METHOD_TYPE, "");
if (methodType.isEmpty()) {
- throw new IllegalArgumentException(METHOD_TYPE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.METHOD_TYPE + IS_NEEDED);
}
- String contentType = props.getProperty(CONTENT_TYPE, "");
+ String contentType = props.getProperty(DmaapClientConst.CONTENT_TYPE, "");
if (contentType.isEmpty()) {
- throw new IllegalArgumentException(CONTENT_TYPE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.CONTENT_TYPE + IS_NEEDED);
}
- String latitude = props.getProperty(LATITUDE, "");
+ String latitude = props.getProperty(DmaapClientConst.LATITUDE, "");
if (latitude.isEmpty()) {
- throw new IllegalArgumentException(LATITUDE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.LATITUDE + IS_NEEDED);
}
- String longitude = props.getProperty(LONGITUDE, "");
+ String longitude = props.getProperty(DmaapClientConst.LONGITUDE, "");
if (longitude.isEmpty()) {
- throw new IllegalArgumentException(LONGITUDE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.LONGITUDE + IS_NEEDED);
}
- String aftEnv = props.getProperty(AFT_ENVIRONMENT, "");
+ String aftEnv = props.getProperty(DmaapClientConst.AFT_ENVIRONMENT, "");
if (aftEnv.isEmpty()) {
- throw new IllegalArgumentException(AFT_ENVIRONMENT + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.AFT_ENVIRONMENT + IS_NEEDED);
}
- String version = props.getProperty(VERSION, "");
+ String version = props.getProperty(DmaapClientConst.VERSION, "");
if (version.isEmpty()) {
- throw new IllegalArgumentException(VERSION + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.VERSION + IS_NEEDED);
}
- String environment = props.getProperty(ENVIRONMENT, "");
+ String environment = props.getProperty(DmaapClientConst.ENVIRONMENT, "");
if (environment.isEmpty()) {
- throw new IllegalArgumentException(ENVIRONMENT + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.ENVIRONMENT + IS_NEEDED);
}
- String subContextPath = props.getProperty(SUB_CONTEXT_PATH, "");
+ String subContextPath = props.getProperty(DmaapClientConst.SUB_CONTEXT_PATH, "");
if (subContextPath.isEmpty()) {
- throw new IllegalArgumentException(SUB_CONTEXT_PATH + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.SUB_CONTEXT_PATH + IS_NEEDED);
}
- String sessionstickinessrequired = props.getProperty(SESSION_STICKINESS_REQUIRED, "");
+ String sessionstickinessrequired = props.getProperty(DmaapClientConst.SESSION_STICKINESS_REQUIRED, "");
if (sessionstickinessrequired.isEmpty()) {
- throw new IllegalArgumentException(SESSION_STICKINESS_REQUIRED + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.SESSION_STICKINESS_REQUIRED + IS_NEEDED);
}
}
private static void validateForNonDME2(Properties props) {
- String host = props.getProperty(HOST, "");
+ String host = props.getProperty(DmaapClientConst.HOST, "");
if (host.isEmpty()) {
- throw new IllegalArgumentException(HOST + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.HOST + IS_NEEDED);
}
- String topic = props.getProperty(TOPIC, "");
+ String topic = props.getProperty(DmaapClientConst.TOPIC, "");
if (topic.isEmpty()) {
- throw new IllegalArgumentException(TOPIC + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.TOPIC + IS_NEEDED);
}
- String contenttype = props.getProperty(CONTENT_TYPE, "");
+ String contenttype = props.getProperty(DmaapClientConst.CONTENT_TYPE, "");
if (contenttype.isEmpty()) {
- throw new IllegalArgumentException(CONTENT_TYPE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.CONTENT_TYPE + IS_NEEDED);
}
- String transportType = props.getProperty(TRANSPORT_TYPE);
+ String transportType = props.getProperty(DmaapClientConst.TRANSPORT_TYPE);
if (!ProtocolType.HTTPNOAUTH.getValue().equalsIgnoreCase(transportType)) {
- String username = props.getProperty(USERNAME, "");
+ String username = props.getProperty(DmaapClientConst.USERNAME, "");
if (username.isEmpty()) {
- throw new IllegalArgumentException(USERNAME + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.USERNAME + IS_NEEDED);
}
- String password = props.getProperty(PASSWORD, "");
+ String password = props.getProperty(DmaapClientConst.PASSWORD, "");
if (password.isEmpty()) {
- throw new IllegalArgumentException(PASSWORD + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.PASSWORD + IS_NEEDED);
}
}
if (ProtocolType.AUTH_KEY.getValue().equalsIgnoreCase(transportType)) {
- String authKey = props.getProperty(AUTH_KEY, "");
+ String authKey = props.getProperty(DmaapClientConst.AUTH_KEY, "");
if (authKey.isEmpty()) {
- throw new IllegalArgumentException(AUTH_KEY + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.AUTH_KEY + IS_NEEDED);
}
- String authDate = props.getProperty(AUTH_DATE, "");
+ String authDate = props.getProperty(DmaapClientConst.AUTH_DATE, "");
if (authDate.isEmpty()) {
- throw new IllegalArgumentException(AUTH_DATE + IS_NEEDED);
+ throw new IllegalArgumentException(DmaapClientConst.AUTH_DATE + IS_NEEDED);
}
}
}
Code Review / dmaap / messagerouter / dmaapclient.git / blobdiff