2011-11-22 4 views
0

resque 작업을 사용하여 인바운드 AMQP 메시지를 처리 ​​할 때 문제를 해결하려고합니다.Thin as Web Server를 사용할 때 Resque 작업자로부터 AMQP 연결에 액세스

이니셜 라이저를 사용하여 응용 프로그램 시작시 메시지 소비자를 설정 한 다음 수신 된 메시지를 다시 처리하여 처리하도록 처리합니다. 그것은 아주 잘 작동하고 있습니다.

그러나 작업자가 응답 메시지를 처리하기를 원합니다. 다시 말해 대기열로 다시 게시하고 포크 프로세스 문제로 실행하여 응용 프로그램 전체 AMQP 연결을 resque 내부에서 주소를 지정할 수 없게 만듭니다. 노동자. 이 패턴이 특이하다고 믿을 수 없기 때문에 다른 사람들이이 문제에 어떻게 대처했는지 보려는 데 매우 흥미가 있습니다.

메시지 볼륨으로 인해 모든 응답에 대해 새 스레드 및 amqp 연결을 시작하는 방법은 실행 가능한 솔루션이 아닙니다.

아이디어가 있으십니까?

답변

0

이것에 나의 흉상은 공 떨어져 나의 눈이 있고 노동자를 걷어차기를 때 포크를 resque에 관하여 잊었다. 그 대신 다른 사람들이 제안한 경로를 따라 가면서 프로세스를 대몬으로 만들었습니다 ....