import org.openecomp.aai.util.AAIConstants;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
-import com.att.nsa.mr.client.MRBatchingPublisher;
-import com.att.nsa.mr.client.MRClientFactory;
+//import com.att.nsa.mr.client.MRBatchingPublisher;
+//import com.att.nsa.mr.client.MRClientFactory;
import com.sun.jersey.api.client.Client;
import com.sun.jersey.api.client.ClientResponse;
import com.sun.jersey.api.client.WebResource;
private static final EELFLogger LOGGER = EELFManager.getInstance().getLogger(AAIDmaapEventJMSConsumer.class);
private final static String COMPONENT = "aaiDmaapEvent";
- private MRBatchingPublisher adp = null;
+ //private MRBatchingPublisher adp = null;
private Properties props;
private Client client;
public AAIDmaapEventJMSConsumer() throws org.apache.commons.configuration.ConfigurationException {
- super();
-
- if (this.adp == null) {
- try {
- FileReader reader = new FileReader(new File(AAIConstants.AAI_EVENT_DMAAP_PROPS));
- props = new Properties();
- props.load(reader);
- props.setProperty("DME2preferredRouterFilePath", AAIConstants.AAI_HOME_ETC_APP_PROPERTIES + "preferredRoute.txt");
- if (props.getProperty("password") != null && props.getProperty("password").startsWith("OBF:")) {
- props.setProperty("password", Password.deobfuscate(props.getProperty("password")));
- }
- this.adp = MRClientFactory.createBatchingPublisher(props);
-
- String host = props.getProperty("host");
- String topic = props.getProperty("topic");
- String protocol = props.getProperty("Protocol");
-
- username = props.getProperty("username");
- password = props.getProperty("password");
- contentType = props.getProperty("contenttype");
-
- url = protocol + "://" + host + "/events/" + topic;
- client = Client.create();
- client.addFilter(new HTTPBasicAuthFilter(username, password));
-
- } catch (IOException e) {
- ErrorLogHelper.logError("AAI_4000", "Error updating dmaap config file for aai event.");
- }
- }
+ //super();
+
+ //if (this.adp == null) {
+ //try {
+ //FileReader reader = new FileReader(new File(AAIConstants.AAI_EVENT_DMAAP_PROPS));
+ //props = new Properties();
+ //props.load(reader);
+ //props.setProperty("DME2preferredRouterFilePath", AAIConstants.AAI_HOME_ETC_APP_PROPERTIES + "preferredRoute.txt");
+ //if (props.getProperty("password") != null && props.getProperty("password").startsWith("OBF:")) {
+ //props.setProperty("password", Password.deobfuscate(props.getProperty("password")));
+ //}
+ //this.adp = MRClientFactory.createBatchingPublisher(props);
+
+ //String host = props.getProperty("host");
+ //String topic = props.getProperty("topic");
+ //String protocol = props.getProperty("Protocol");
+
+ //username = props.getProperty("username");
+ //password = props.getProperty("password");
+ //contentType = props.getProperty("contenttype");
+
+ //url = protocol + "://" + host + "/events/" + topic;
+ //client = Client.create();
+ //client.addFilter(new HTTPBasicAuthFilter(username, password));
+
+ //} catch (IOException e) {
+ //ErrorLogHelper.logError("AAI_4000", "Error updating dmaap config file for aai event.");
+ //}
+ //}
}
@Override
public void onMessage(Message message) {
- String jsmMessageTxt = "";
- String aaiEvent = "";
- String transId = "";
- String fromAppId = "";
- String fullId = "";
-
- if (message instanceof TextMessage) {
- try {
- jsmMessageTxt = ((TextMessage) message).getText();
- JSONObject jo = new JSONObject(jsmMessageTxt);
-
- if (jo.has("aaiEventPayload")) {
- aaiEvent = jo.getJSONObject("aaiEventPayload").toString();
- } else {
- return;
- }
- if (jo.getString("transId") != null) {
- MDC.put("requestId", jo.getString("transId"));
- }
- if (jo.getString("fromAppId") != null) {
- MDC.put("partnerName", jo.getString("fromAppId"));
- }
- if (jo.getString("fullId") != null) {
- fullId = jo.getString("fullId");
- }
-
- LOGGER.info(fullId + "|" + transId + "|" + fromAppId + "|" + aaiEvent);
-
- String environment = System.getProperty("lrmRO");
-
- if (environment == null) {
- this.adp.send(aaiEvent);
- } else {
- if (environment.startsWith("dev") || environment.startsWith("testINT") || environment.startsWith("testEXT")) {
-
- WebResource webResource = client.resource(url);
-
- ClientResponse response = webResource.accept(contentType).type(MediaType.APPLICATION_JSON).post(ClientResponse.class, aaiEvent);
-
- if (response.getStatus() != 200) {
- System.out.println("Failed : HTTP error code : " + response.getStatus());
- }
- } else {
- this.adp.send(aaiEvent);
- }
- }
-
- } catch (IOException e) {
- if (e instanceof java.net.SocketException) {
- if (e.getMessage().contains("Connection reset")) {
- } else {
- ErrorLogHelper.logError("AAI_7304", "Error reaching DMaaP to send event. " + aaiEvent);
- }
- } else {
- ErrorLogHelper.logError("AAI_7304", "Error reaching DMaaP to send event. " + aaiEvent);
- }
- } catch (JMSException | JSONException e) {
- ErrorLogHelper.logError("AAI_7350", "Error parsing aaievent jsm message for sending to dmaap. " + jsmMessageTxt);
- }
- }
+ //String jsmMessageTxt = "";
+ //String aaiEvent = "";
+ //String transId = "";
+ //String fromAppId = "";
+ //String fullId = "";
+
+ //if (message instanceof TextMessage) {
+ //try {
+ //jsmMessageTxt = ((TextMessage) message).getText();
+ //JSONObject jo = new JSONObject(jsmMessageTxt);
+
+ //if (jo.has("aaiEventPayload")) {
+ //aaiEvent = jo.getJSONObject("aaiEventPayload").toString();
+ //} else {
+ //return;
+ //}
+ //if (jo.getString("transId") != null) {
+ //MDC.put("requestId", jo.getString("transId"));
+ //}
+ //if (jo.getString("fromAppId") != null) {
+ //MDC.put("partnerName", jo.getString("fromAppId"));
+ //}
+ //if (jo.getString("fullId") != null) {
+ //fullId = jo.getString("fullId");
+ //}
+
+ //LOGGER.info(fullId + "|" + transId + "|" + fromAppId + "|" + aaiEvent);
+
+ //String environment = System.getProperty("lrmRO");
+
+ //if (environment == null) {
+ //this.adp.send(aaiEvent);
+ //} else {
+ //if (environment.startsWith("dev") || environment.startsWith("testINT") || environment.startsWith("testEXT")) {
+
+ //WebResource webResource = client.resource(url);
+
+ //ClientResponse response = webResource.accept(contentType).type(MediaType.APPLICATION_JSON).post(ClientResponse.class, aaiEvent);
+
+ //if (response.getStatus() != 200) {
+ //System.out.println("Failed : HTTP error code : " + response.getStatus());
+ //}
+ //} else {
+ //this.adp.send(aaiEvent);
+ //}
+ //}
+
+ //} catch (IOException e) {
+ //if (e instanceof java.net.SocketException) {
+ //if (e.getMessage().contains("Connection reset")) {
+ //} else {
+ //ErrorLogHelper.logError("AAI_7304", "Error reaching DMaaP to send event. " + aaiEvent);
+ //}
+ //} else {
+ //ErrorLogHelper.logError("AAI_7304", "Error reaching DMaaP to send event. " + aaiEvent);
+ //}
+ //} catch (JMSException | JSONException e) {
+ //ErrorLogHelper.logError("AAI_7350", "Error parsing aaievent jsm message for sending to dmaap. " + jsmMessageTxt);
+ //}
+ //}
}
}
package org.openecomp.aai.dmaap;
-import org.apache.activemq.ActiveMQConnectionFactory;
-import org.apache.activemq.command.ActiveMQQueue;
+//import org.apache.activemq.ActiveMQConnectionFactory;
+//import org.apache.activemq.command.ActiveMQQueue;
import org.json.JSONObject;
-import org.springframework.jms.connection.CachingConnectionFactory;
-import org.springframework.jms.core.JmsTemplate;
+//import org.springframework.jms.connection.CachingConnectionFactory;
+//import org.springframework.jms.core.JmsTemplate;
public class AAIDmaapEventJMSProducer {
- private JmsTemplate jmsTemplate;
+ //private JmsTemplate jmsTemplate;
public AAIDmaapEventJMSProducer() {
- this.jmsTemplate = new JmsTemplate();
- this.jmsTemplate.setConnectionFactory(new CachingConnectionFactory(new ActiveMQConnectionFactory("tcp://localhost:61446")));
- this.jmsTemplate.setDefaultDestination(new ActiveMQQueue("IN_QUEUE"));
+ //this.jmsTemplate = new JmsTemplate();
+ //this.jmsTemplate.setConnectionFactory(new CachingConnectionFactory(new ActiveMQConnectionFactory("tcp://localhost:61446")));
+ //this.jmsTemplate.setDefaultDestination(new ActiveMQQueue("IN_QUEUE"));
}
public void sendMessageToDefaultDestination(JSONObject finalJson) {
- jmsTemplate.convertAndSend(finalJson.toString());
- CachingConnectionFactory ccf = (CachingConnectionFactory)this.jmsTemplate.getConnectionFactory();
- ccf.destroy();
+ //jmsTemplate.convertAndSend(finalJson.toString());
+ //CachingConnectionFactory ccf = (CachingConnectionFactory)this.jmsTemplate.getConnectionFactory();
+ //ccf.destroy();
}
}
<url>dav:${nexusproxy}${sitePath}</url>
</site>
</distributionManagement>
-
- <!-- The standard build tasks for this project are inherited from the parent.
- Please do not override the build tasks. However tasks and/or profiles can
- be included here as well as additional dependencies for your service. Any
- runtime or compile scope dependencies will be copied to the INSTALLATION_PATH/extJars
- folder and will be made available on the AJSC classpath for your service.
- Please, NOTE: DME2 and CSM related dependencies are EXTERNALIZED within the
- CSI environment. Therefore, they are provided within this project as "provided"
- dependencies. In order for the AJSC to run properly, locally, the CSM and
- DME2 dependencies will be copied into the target/commonLibs folder and will
- be made available to the classpath of the AJSC through the use of the system
- property, "AJSC_EXTERNAL_LIB_FOLDERS". This system property needs to be set
- in the "runAjsc" maven profile within the pom.xml (and, is defaulted to do
- so). If you have a startup failure related to a missing dme2 class not found
- exception, please contact the AJSC team for assistance.-->
- <dependencies>
- <dependency>
- <groupId>csi-schemas-source</groupId>
- <artifactId>cmn-CommonDataModel</artifactId>
- <version>100.0.145</version>
- </dependency>
- </dependencies>
<profiles>
<profile>
<id>jenkins-properties</id>
Code Review / aai / traversal.git / commitdiff