Simple pipe from ActiveMQ to RabbitMQ

clamq_samples1.clj

(ns clamq-samples1 (:use [clamq.protocol] [clamq.jms] [clamq.activemq] [clamq.rabbitmq] [clamq.pipes]))

(def activemq (jms-connection (activemq-connection "tcp://localhost:61616")))
(def rabbitmq (rabbitmq-connection "localhost"))

(open 
  (pipe {
    :from {:connection activemq :endpoint "activemq"} 
    :to {:connection rabbitmq :endpoint {:routing-key "rabbitmq"}} 
    :transacted true
  }))