package org.onap.appc.adapter.chef.chefclient;
import java.io.BufferedReader;
-import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.security.InvalidKeyException;
public static String sha1AndBase64(String inStr) {
MessageDigest md = null;
- String outStr = null;
byte[] outbty = null;
try {
md = MessageDigest.getInstance("SHA-1");
public class DmaapMessageAdapterFactoryImpl implements MessageAdapterFactory {
+ @Override
public Producer createProducer(Collection<String> pools, String writeTopic, String apiKey, String apiSecret) {
return new DmaapProducerImpl(pools, writeTopic,apiKey, apiSecret);
}
+ @Override
public Producer createProducer(Collection<String> pools, Set<String> writeTopics, String apiKey, String apiSecret) {
return new DmaapProducerImpl(pools, writeTopics, apiKey, apiSecret);
}
+ @Override
public Consumer createConsumer(Collection<String> pool, String readTopic,
- String clientName, String clientId, String filter_json, String apiKey, String apiSecret) {
- return new DmaapConsumerImpl(pool, readTopic, clientName, clientId, apiKey, apiSecret, filter_json);
+ String clientName, String clientId, String filterJson, String apiKey, String apiSecret) {
+ return new DmaapConsumerImpl(pool, readTopic, clientName, clientId, apiKey, apiSecret, filterJson);
}
}
public static MessageService parse(String input) {
if (input != null) {
for (MessageService ms : MessageService.values()) {
- if (ms.getValue().equals(input.toLowerCase())) {
+ if (input.equalsIgnoreCase(ms.getValue())) {
return ms;
}
}
*/
public class Constants {
+ private Constants() {
+ }
+
public static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";
public static final String MDC_SERVICE = "service";
*/
public class Property {
+ private Property() {
+ }
public static final String PROVIDER = "provider";
public static final String PROVIDER_IDENTITY = "identity";
public static final String PROVIDER_TENANT = "tenant";
*/
public enum Operation {
EVACUATE_SERVICE {
+ @Override
public String toString() {
return "evacuateServer";
}
},
MIGRATE_SERVICE {
+ @Override
public String toString() {
return "migrateServer";
}
},
REBUILD_SERVICE {
+ @Override
public String toString() {
return "rebuildServer";
}
},
RESTART_SERVICE {
+ @Override
public String toString() {
return "restartServer";
}
},
VMSTATUSCHECK_SERVICE {
+ @Override
public String toString() {
return "vmStatuschecker";
}
},
SNAPSHOT_SERVICE {
+ @Override
public String toString() {
return "createSnapshot";
}
},
TERMINATE_STACK {
+ @Override
public String toString() {
return "terminateStack";
}
},
SNAPSHOT_STACK {
+ @Override
public String toString() {
return "snapshotStack";
}
},
START_SERVICE {
+ @Override
public String toString() {
return "startServer";
}
},
STOP_SERVICE {
+ @Override
public String toString() {
return "stopServer";
}
},
TERMINATE_SERVICE {
+ @Override
public String toString() {
return "terminateServer";
}
},
LOOKUP_SERVICE {
+ @Override
public String toString() {
return "lookupServer";
}
},
RESTORE_STACK {
+ @Override
public String toString() {
return "restoreStack";
}
},
ATTACHVOLUME_SERVICE {
+ @Override
public String toString(){
return "attachVolume";
}
},
DETACHVOLUME_SERVICE {
+ @Override
public String toString(){
return "dettachVolume";
}
*/
public enum Outcome {
FAILURE {
+ @Override
public String toString() {
return "failure";
}
},
SUCCESS {
+ @Override
public String toString() {
return "success";
}
private static final long serialVersionUID = -155423437162622414L;
public DataAccessException(){
+ // DataAccessException
}
public DataAccessException(String message){
private static final long serialVersionUID = -155423437162622414L;
public NetconfDAOException(){
+ // for NetconfDAOException
}
public NetconfDAOException(String message){
public class Constants {
+ private Constants() {
+ }
+
public static final String CONFIGURE_PATH = "/restconf/config/opendaylight-inventory:nodes/node/";
public static final String CONNECT_PATH = "/restconf/config/opendaylight-inventory:nodes/node/controller-config/yang-ext:mount/config:modules";
public static final String CHECK_CONNECTION_PATH = "/restconf/operational/opendaylight-inventory:nodes/node/";
*/
package org.onap.appc.adapter.restHealthcheck;
-import org.onap.appc.Constants;
import org.onap.appc.adapter.restHealthcheck.impl.RestHealthcheckAdapterImpl;
import org.onap.appc.configuration.Configuration;
-import org.onap.appc.configuration.ConfigurationFactory;
-import org.onap.appc.i18n.Msg;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import org.osgi.framework.BundleActivator;
private ServiceRegistration registration = null;
private static final EELFLogger logger = EELFManager.getInstance().getLogger(RestHealthcheckActivator.class);
- /**
- * The configuration object used to configure this bundle
- */
- private Configuration configuration;
-
/**
* Called when this bundle is started so the Framework can perform the bundle-specific activities necessary to start
* this bundle. This method can be used to register services or to allocate any resources that this bundle needs.
Code Review / appc.git / commitdiff