     [clojure.tools.cli      :as   cli   ]
     [clojure.tools.logging  :as   log   ]
     [clojure.edn            :as   edn   ]
+    [cheshire.core          :as   ches  ]
     [clojure.core.async     :refer 
       [alts! chan go thread timeout 
        >! >!! <! <!! go-loop]           ]


        (thread
          (Thread/sleep 100)
          (doseq [json-doc jsons]
            (blocking-producer work-chan json-doc)))

        ;; end of sending thread

                              (StoreValue$Builder. riak-object) riak-key) 
                                StoreValue$Option/N_VAL (Integer. 1)))
        exx             (.execute riak-client store)
      ]
    {:ok :ok}))

(def blocking-producer >!!)
(def blocking-consumer <!!)
