diff options
| author |   Shwetank Dave <shwetank.dave@amdocs.com> | 2018-09-12 16:45:03 -0400 |
|---|---|---|
| committer | Shwetank Dave <shwetank.dave@amdocs.com> | 2018-09-12 16:45:43 -0400 |
| commit | 220e170103ae5711addcfd84f597fc06a5e3aaca (patch) | |
| tree | 8c1448f0300ae4fe4737a9eb1cc085967599d936 /src/chameleon/kafka.clj | |
| parent | fd9231d0362656f508afdba877bbada9ae20aac0 (diff) | |
Updating test to fix daily build job.
Change-Id: I5dce0888f0e21bb253eee23da6b998480522deb5
Issue-ID: AAI-1547
Signed-off-by: Shwetank Dave <shwetank.dave@amdocs.com>
Diffstat (limited to 'src/chameleon/kafka.clj')
| -rw-r--r-- | src/chameleon/kafka.clj | 4 |
1 files changed, 4 insertions, 0 deletions
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 |