Snippets to access Darwin feed v16 (Camel + ActiveMQ)

darwin.clj

(import 'org.apache.activemq.camel.component.ActiveMQComponent)

...

(defn- ^String activemq-source-path
  [{:keys [user password broker-url topic] :as consumer-config}]
  (format "activemq:topic:%s?username=%s&password=%s"
          topic
          user
          password))
          
(defn activemq-component
  [config]
  (ActiveMQComponent/activeMQComponent  (get-in config [:broker-url])))
  
  
;; cfg
  
(def cfg {:topic "darwin.pushport-v16",
          :user "DARWIN-FOOBAR-UUID",
          :password nil, ;; FIXME
          :broker-url "tcp://darwin-dist-44ae45.nationalrail.co.uk:61616?jms.watchTopicAdvisories=false"})
 
(.. builder
    (from (activemq-source-path cfg)))
...