조금 혼란 스럽습니다. 주제 교환을 구현하려고하는데 필요한 것이 무엇인지 확신 할 수 없습니다. 여러 개의 라우팅 키와 1 개의 주제 교환 (기본 amq.topic)이 필요합니다. .. 내 키는 것과 같다 : * 는 는 고객을 customer.appB.created customer.appA.created 만들어 내 큐 (들)은 내구성이 할 , 하지만 app
RackbitMQ가 고정되지 않은 메시지로 "붙어 있습니다". 대기열에는 더 이상 존재하지 않는 소비자가 표시되며 RabbitMQ가 해당 소비자에게 메시지를 계속 전달한다는 사실을 가정합니다. 그들은 계속 늘어나지 않은 메시지를 보여줍니다. 나는 php-amqplib로 PHP에서 이것을하고있다. 나는 소비자 프로세스 (명령 줄에서 control-C)를 종료
The example code for RabbitMQ 상태 우리의 코드를 차단합니다. 메시지를받을 때마다 $ $ 콜백 함수가 메시지를 전달합니다. 이 코드 이는 the default timeout for PhpAmqpLib\Channel\AbstractChannel::wait is forever 때문에, 저를 혼란 while(count($channel->c
OldSoundRabbitMqBundle을 사용하여 RabbitMQ 소비자를 실행하는 Symfony 3.1.x 프로젝트가있는 RabbitMQ 컨테이너와 PHP 7 컨테이너가 있습니다. test 소비자 실행이 명령을 실행하는 경우 : 나는 다음과 같은 오류가 bin/console rabbitmq:consumer -w test
을 : [PhpAmqpLib\
나는 rabbitmq 소비자에 대한 2 개 질문 (수신기)이 있습니다 이 어떻게 (정적 큐에서) 정의 할 수 있습니다 특정 대기열에 등록 된 소비자가 무엇을 그렇게 하나 개 소비자는 메시지 아래 인 경우 해당 소비자가 다시 올라온 후에도 계속 제공 될 것입니까? 아니면이를 달성 할 다른 방법이 있습니까? 소비자가 아직 생성되지 않은 대기열에 rabbitmq
등록 된 웹 후크에 대한 데이터를 제출할 때 RabbitMq을 사용하고 있습니다. 기본 정보 : 연락처가 시스템에서 생성되는 경우, 메시지가 큐에 배치되고, 소비자는 등록 된 URL로 나중에 훅 데이터를 전송한다. 내 질문에 : 연락처가 5 초에 두 번 업데이트되고 두 메시지가 모두 대기열에 남아있을 수 있습니다. 그러나 두 번째 메시지가 대기중인 경우 첫
third RabbitMQ tutorial에 관한 질문이 있습니다. 생산자가 교환기로 메시지를 보낼 때 소비자가 실행될 것이라는 보장이 없다는 점을 제외하고 비슷한 것을 구현하려고합니다. 그래서, 팬 아웃 교환에 메시지를 게시 내 생산이 : list($queueName,,) = $channel->queue_declare("", false, false, tr