This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2016-02-28
Channels
- # aatree (1)
- # announcements (1)
- # beginners (18)
- # boot (12)
- # cljsjs (1)
- # cljsrn (6)
- # clojure (358)
- # clojure-japan (1)
- # clojure-russia (69)
- # clojurescript (20)
- # core-async (32)
- # cursive (6)
- # datomic (57)
- # devcards (3)
- # dirac (2)
- # editors (8)
- # emacs (6)
- # juxt (1)
- # ldnclj (4)
- # luminus (2)
- # om (91)
- # om-next (2)
- # onyx (11)
- # reagent (7)
Hi @a.espolov. Could you clarify the question a bit?
I have the option of using immutant for my goal, that's what I want. 1. perform a get request every minute and put the result in the cache 2. Message queue which is processed on all dataflow diagram, in the processing of data for the cache
That should be possible to implement. You might need to create an input plugin for the get request part though.
Assuming I’m understanding you correctly, that is
Basically you have a message queue (one datasource) and a http server (a second datasource) and you want to process the message queue using the cache you retrieved from the http server datasource
Actually you probably don’t even need an input plugin
You could use a lifecycle function on a task to retrieve the cache every minute