From 220e170103ae5711addcfd84f597fc06a5e3aaca Mon Sep 17 00:00:00 2001
From: Shwetank Dave <shwetank.dave@amdocs.com>
Date: Wed, 12 Sep 2018 16:45:03 -0400
Subject: Updating test to fix daily build job.

Change-Id: I5dce0888f0e21bb253eee23da6b998480522deb5
Issue-ID: AAI-1547
Signed-off-by: Shwetank Dave <shwetank.dave@amdocs.com>
---
 src/chameleon/kafka.clj | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'src/chameleon/kafka.clj')

diff --git a/src/chameleon/kafka.clj b/src/chameleon/kafka.clj
index ae8e77f..bdfc07d 100644
--- a/src/chameleon/kafka.clj
+++ b/src/chameleon/kafka.clj
@@ -36,6 +36,10 @@
                                           (into ["SPEC ERROR"])
                                           (mapv str))))))
 
+(defn clj-kafka-comsumer?
+  [consumer]
+  (instance? CljKafkaConsumer consumer))
+
 (defn subscribe
   "Given a CljKafkaConsumer, a channel, and a session timeout (in
   ms), return a channel.  The input channel is where the messages will
-- 
cgit 1.2.3-korg