fix default properties 01/41501/2
authorVijay VK <vv770d@att.com>
Fri, 6 Apr 2018 21:38:58 +0000 (22:38 +0100)
committerVENKATESH KUMAR <vv770d@att.com>
Sat, 7 Apr 2018 04:49:31 +0000 (00:49 -0400)
Change-Id: Iae00d76ac70d6fc318d54151f99ec58eb8188aac
Signed-off-by: VENKATESH KUMAR <vv770d@att.com>
Issue-ID: DCAEGEN2-434

etc/collector.properties
mvn-phase-lib.sh
src/main/java/org/onap/dcae/commonFunction/EventProcessor.java
swagger_vescollector.yaml

index c0db015..ab5febc 100755 (executable)
@@ -46,7 +46,7 @@ collector.schema.checkflag=1
 collector.schema.file={\"v1\":\"./etc/CommonEventFormat_27.2.json\",\"v2\":\"./etc/CommonEventFormat_27.2.json\",\"v3\":\"./etc/CommonEventFormat_27.2.json\",\"v4\":\"./etc/CommonEventFormat_27.2.json\",\"v5\":\"./etc/CommonEventFormat_28.4.1.json\"}\r
 \r
 ## List all streamid per domain to be supported. The streamid should match to channel name on dmaapfile  \r
-collector.dmaap.streamid=fault=ves_fault,ves_fault_secondary|syslog=ves_syslog,ves_syslog_secondary|heartbeat=ves_heartbeat,ves_heartbeat_secondary|measurementsForVfScaling=ves_measurement,ves_measurement_secondary|mobileFlow=ves_mobileflow,ves_mobileflow_secondary|other=ves_other,ves_other_secondary|stateChange=ves_statechange,ves_statechange_secondary|thresholdCrossingAlert=ves_thresholdCrossingAlert,ves_thresholdCrossingAlert_secondary|voiceQuality=ves_voicequality,ves_voicequality_secondary|sipSignaling=ves_sipsignaling,ves_sipsignaling_secondary\r
+collector.dmaap.streamid=fault=ves_fault|syslog=ves_syslog|heartbeat=ves_heartbeat|measurementsForVfScaling=ves_measurement|mobileFlow=ves_mobileflow|other=ves_other|stateChange=ves_statechange|thresholdCrossingAlert=ves_thresholdCrossingAlert|voiceQuality=ves_voicequality|sipSignaling=ves_sipsignaling\r
 collector.dmaapfile=./etc/DmaapConfig.json\r
 \r
 ## Custom ExceptionConfiguration\r
index d3c3f25..ac53722 100755 (executable)
@@ -237,7 +237,7 @@ build_and_push_docker()
   VERSION="${MVN_PROJECT_VERSION//[^0-9.]/}"
   VERSION2=$(echo "$VERSION" | cut -f1-2 -d'.')
 
-  LFQI="${IMAGENAME}:${VERSION}-${TIMESTAMP}"
+  LFQI="${IMAGENAME}:${VERSION}-${TIMESTAMP}"Z
   # build a docker image
   docker build --rm -f ./Dockerfile -t "${LFQI}" ./
 
@@ -279,7 +279,7 @@ build_and_push_docker()
     fi
 
     OLDTAG="${LFQI}"
-    PUSHTAGS="${REPO}/${IMAGENAME}:${VERSION2}-${TIMESTAMP} ${REPO}/${IMAGENAME}:${VERSION2} ${REPO}/${IMAGENAME}:${VERSION2}-latest"
+    PUSHTAGS="${REPO}/${IMAGENAME}:${VERSION}-SNAPSHOT-${TIMESTAMP}Z ${REPO}/${IMAGENAME}:${VERSION} ${REPO}/${IMAGENAME}:latest"
     for NEWTAG in ${PUSHTAGS}
     do
       echo "tagging ${OLDTAG} to ${NEWTAG}"
index 462287e..d41cb23 100644 (file)
@@ -70,13 +70,14 @@ public class EventProcessor implements Runnable {
                try {\r
 \r
                        event = CommonStartup.fProcessingInputQueue.take();\r
-                       log.info("QueueSize:" + CommonStartup.fProcessingInputQueue.size()+  "\tEventProcessor\tRemoving element: " + event );\r
+                       \r
 \r
                        // EventPublisher Ep=new EventPublisher();\r
                        while (event != null) {\r
                                // As long as the producer is running we remove elements from\r
                                // the queue.\r
-\r
+                               log.info("QueueSize:" + CommonStartup.fProcessingInputQueue.size()+  "\tEventProcessor\tRemoving element: " + event );\r
+                               \r
                                String uuid = event.get("VESuniqueId").toString();\r
                                LoggingContext localLC = VESLogger.getLoggingContextForThread(uuid);\r
                                localLC.put(EcompFields.kBeginTimestampMs, SaClock.now());\r
index 6acae21..7e27fad 100644 (file)
@@ -17,7 +17,7 @@
 # ECOMP is a trademark and service mark of AT&T Intellectual Property.
 swagger: '2.0'
 info:
-  version: 1.1.0
+  version: 1.2.0
   title: VES Collector
   description: >
     Virtual Event Streaming (VES) Collector is RESTful collector for processing