diff options
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))))))))))) )) |