Skip to content

Commit 75aa7fb

Browse files
committed
[els] cleaner and more intuitive publishing function
1 parent 9f24a8a commit 75aa7fb

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

mulog-elasticsearch/src/com/brunobonacci/mulog/publishers/elasticsearch.clj

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,8 +226,8 @@
226226
buffer
227227
;; else send to ELS
228228
(do
229-
(some->> (seq (transform (map second items)))
230-
(post-records config))
229+
(when-let [records (not-empty (transform (map second items)))]
230+
(post-records config records))
231231
(rb/dequeue buffer last-offset))))))
232232

233233

0 commit comments

Comments
 (0)