diff options
author | James Forsyth <jf2512@att.com> | 2018-04-19 13:22:42 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2018-04-19 13:22:42 +0000 |
commit | 8e52114cf9289dd85c8838bf0eb8c24f5e2c7f99 (patch) | |
tree | 9810e6db0a6f8dc167bd23ca3db4a24f15939490 /src/chameleon/event.clj | |
parent | a99f8b47866dbdd0afd5a563ef9f8896501f62e6 (diff) | |
parent | f796373d7de201c0a46f06b3155b1734b9872bb3 (diff) |
Merge "Fix graphwalk capabilities"
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))))))))))) )) |