컨텍스트 : Clojure + RabbitMQ (Langohr을 통해), 후속 작업은 this question입니다. RabbitMQ mq (직접 교환기에서 메시지를 가져 와서 메시지 처리 후 팬 아웃 교환기에 게시)에서 메시지를 소비하는 데 이상한 결과가 나타납니다. 왜 메시지가 결국 개의 개별 스레드에 쓰이는 지 이해할 수 없습니다. (몇 개의 메시지마
나는 web-page에있는 RabbitMQ 튜토리얼을 실행 중이고 좀 더 일반적이고 구성하기 쉽도록 예제를 리펙토링하려고 노력 중이다. 나는 두 번째 "blabbr"예에 머물러있다. 내가 매크로하고 다음과 같이 함수에서 호출 수 있다고 생각 (defn -main
[& args]
(let [conn (rmq/connect)
ch
토끼 대기열에서 읽는 Clojure 코드가 있습니다. 우리는 RabbitMQ 서버가 잠시 중단 된 경우를 용인하고자합니다. 다시 시작한 경우 (sudo service rabbitmq-server restart). Langohr에는 some provision for reconnecting이있는 것으로 보입니다. 예 : clojurewerkz.langohr.e
페이로드와 헤더를 읽고 인쇄중인 langohr 메시지 처리기가 있습니다. 문제는 교환기에 메시지를 게시 할 때 쿼리 헤더를 문서화 할 수 없으므로 (헤더 "h1"을 얻지 못함) 원시적 인 클로저 맵이 아닙니다. 여기서 내가 뭘 잘못하고 있니? (defn status-handler [ch {:keys [headers]} ^bytes payload]