amqp

0열

1답변

Thin as Web Server를 사용할 때 Resque 작업자로부터 AMQP 연결에 액세스

resque 작업을 사용하여 인바운드 AMQP 메시지를 처리 할 때 문제를 해결하려고합니다. 이니셜 라이저를 사용하여 응용 프로그램 시작시 메시지 소비자를 설정 한 다음 수신 된 메시지를 다시 처리하여 처리하도록 처리합니다. 그것은 아주 잘 작동하고 있습니다. 그러나 작업자가 응답 메시지를 처리하기를 원합니다. 다시 말해 대기열로 다시 게시하고 포크 프

0열

1답변

이벤트 머신과 레일이있는 여러 작업자

EventMachine 및 amqp과 rails을 사용하는 방법을 알아 내는데 약간 문제가 있습니다. 내가 찾은 튜토리얼의 대부분은 대기열에 추가 할 수있는 '제작자'를 설정하는 것이 었습니다. 그 반대의 작업을 수행 할 필요가 있습니다. 파이썬 응용 프로그램에서 항목을 대기열에 제출하고 대기열에서 항목을 선택하여 처리해야하는 레일 응용 프로그램이 필요합니

9열

2답변

연결이없는 AMQP/RabbitMQ 채널은 언제 죽을까요?

나는 간단한 RabbitMQ 테스트 프로그램을 무작위로 메시지를 대기시키고 있고, 다른 하나는 Spring-AMQP를 사용하고있다. 소비자가 사망 한 경우 (예 : 연결 또는 채널을 닫을 기회없이 프로세스를 종료하는 경우) 승인되지 않은 메시지는 영원히 미확인 상태로 남습니다. 채널이 연결되어 있지 않을 때 채널이 종료되고 나머지 unack'd 메시지가 다

8열

4답변

RabbitMQ가있는 작업자 풀 및 멀티 테넌트 (multi-tenant) 대기열

다중 테넌트 클라우드 기반 응용 프로그램 (다수의 클라이언트, 별도의 "환경"이 있지만 모두 공유 하드웨어 집합) 인 웹 응용 프로그램에서 작업하고 우리는 사용자가 나중에 처리하기 위해 일괄 처리하는 기능을 도입했습니다. 배치 작업의 유형은 실제로 중요하지 않습니다. 작업 대기열없이 작업하는 것이 실제로 실용적이지는 않습니다. RabbitMQ를 기본 큐 프

6열

2답변

내 메시지가 spring amqp와 함께 성공적으로 전송되었음을 어떻게 알 수 있습니까?

RabbitTemplate 클래스를 사용하여 spring amqp로 RabbitMQ 큐에 쓰고 있습니다. convertAndSend 메서드를 사용하여 메시지를 큐에 보냅니다. 이는 정상적인 상황에서는 잘 작동하지만 대기열이 없으면 자동으로 실패하는 것 같습니다. 예외가 발생하지 않고 오류/디버그 메시지가 로거에 기록되지 않습니다. 메시지 배달 여부를 확인하

2열

1답변

PHP 드라이버 AMQP 제거

왜이 방법으로 대기열 이름을 지정해야합니까? , ACK 얻을 심하게 설계된 인터페이스의 일례이다

9열

1답변

RabbitMQ 및 승인

내 프로젝트 중 하나는 RabbitMQ 사용에 대한 인증이 필요합니다. 인증 된 사용자 만이 rabbitmq 서버에 연결하여 대기열에 가입 할 수 있습니다. 예를 들어, 사용자가 처음 서버에 연결하고 로그인 (password)과 같은 인증 데이터를 전송하면 서버가이를 확인하고 사용자 전달 된 인증을 사용하면 큐에 등록 할 수 있습니다. 그렇지 않으면 서버가

3열

1답변

HTTP를 통한 터널링 AMQP?

AMQP 기반 응용 프로그램에 HTTP 게이트웨이를 제공하기위한 표준 라이브러리 또는 패키지 (파이썬 지향적 인 것이 좋음)가 있습니까? 예 : 호스트 간의 통신에 AMQP를 사용하는 응용 프로그램이 있고 네트워크가 HTTP 이외의 트래픽을 허용하지 않을 수있는 상황의 경우 마이그레이션 경로를 원합니다.

6열

2답변

해당 작업을 가져올 수 없을 때 셀러리 작업 실행

두 개의 서버가 있습니다 : 하나는 django 응용 프로그램을 실행하고 다른 하나는 rabbitmq 대기열과 셀러리 작업자를 실행하는 서버입니다. 다음과 같이 큐/근로자를 실행하는 서버에 내 tasks.py는 작업을 포함 @task(queue="reports") def test_task(): time.sleep(120) 내 목표는 장고보기에

1열

1답변

AMQP를 JTA와 함께 사용

CMQ/JTA 환경에서 AMQP 클라이언트를 사용하는 좋은 예가 있습니까? AMQP가 트랜잭션 메시징을 지원한다는 것을 알고 있지만 JTA와 어떻게 조화를 이루지는 않습니다. 지금까지 Apache Qpid Java 브로커를 설치하고 독립 실행 형 JTA로 최신 JBossTS (Narayana 5.0.0.M1)를 사용하여 Java 응용 프로그램에서 연결했습니