diff options
| author |   Adrian Batos-Parac <adrian.batos-parac@amdocs.com> | 2018-04-12 15:31:45 -0400 |
|---|---|---|
| committer | Adrian Batos-Parac <adrian.batos-parac@amdocs.com> | 2018-04-13 11:43:08 -0400 |
| commit | f796373d7de201c0a46f06b3155b1734b9872bb3 (patch) | |
| tree | ebe0f754f59f775e01d5e121411c770e72bdba31 /src/chameleon/event.clj | |
| parent | 48f6bc8f4089730dbd6ff42f02a923e642887e93 (diff) | |
Fix graphwalk capabilities
Fixes the issue where graphwalk was not working properly in the
chameleon code within ONAP.
Change-Id: Iae1dd036f10ab6443a40cac66ae69fad77036cb2
Issue-ID: AAI-797
Signed-off-by: Adrian Batos-Parac <adrian.batos-parac@amdocs.com>
Diffstat (limited to 'src/chameleon/event.clj')
| -rw-r--r-- | src/chameleon/event.clj | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/chameleon/event.clj b/src/chameleon/event.clj index 8201acb..2b32d26 100644 --- a/src/chameleon/event.clj +++ b/src/chameleon/event.clj @@ -1,7 +1,8 @@ (ns chameleon.event (:require [chameleon.txform] [chameleon.route] - [integrant.core :as ig]) + [integrant.core :as ig] + [clojure.string :refer [starts-with?]]) (:import [org.onap.aai.event.client DMaaPEventConsumer])) (defmethod ig/init-key :chameleon/event @@ -13,6 +14,8 @@ (let [it (.iterator (.consume event-processor))] (println "Polling...") (while (.hasNext it) - (let [event (.next it)] - (processor gallifrey-host event)))))))) + (try (let [event (.next it)] + (if (not (starts-with? event "DMAAP")) ;Temporarily added for current version of dmaap client + (processor gallifrey-host event))) + (catch Exception e (println (str "Unexpected exception during processing: " (.getMessage e))))))))))) )) |