amqp

3열

1답변

여러 대기열에 게시 할 때 Pika basic_publish가 중단됩니다.

교환기에서 여러 대기열을 설정해야합니다. 단일 연결을 만든 다음 여러 대기열을 선언 (이 작동) 한 다음 여러 대기열에 메시지를 게시합니다 (작동하지 않음). 이렇게하려면 몇 가지 테스트 코드를 설정했지만 2 번에 게시 중단 될 때마다 게시됩니다. 이 코드는 단일 큐 (단일 큐의 여러 메시지조차도)에 게시 할 때 작동하므로 연결을 닫지 않고 여러 큐에 게시

2열

1답변

Spring Integration과 RabbitMQ, 인바운드 채널 어댑터에서 폴링을 피할 수있는 방법은 무엇입니까?

현재 직접 교환으로 Rabbit MQ Broker 설정이 있고 대기열에서 메시지를 생성하고 소비하기 위해 Spring Integration을 사용하고 있습니다. SI를 사용하여 하나의 POJO에서 다른 POJO로 소비 된 메시지를 전달하는 책임 체인 패턴을 사용하고 있습니다. 이제는 Spring Integration 인바운드 채널 어댑터를 사용했습니다. 이

2열

1답변

rabbitmqadmin을 사용하여 CloudAMQP/Heroku에 액세스

AMQP 및 RabbitMQ에 대해 배우기 시작했습니다. 나는 Mac OS X 상자에서 만든 RabbitMQ 개발 설치에 데이터를 성공적으로 게시하기 위해 CLI 도구 인 rabbitmqadmin을 사용했습니다. 지금까지는 너무 좋아서 메시지를 게시하고 큐에서 대기열을 볼 수 있습니다. 그러나 Heroku/CloudAMQP 인스턴스에서 똑같은 기능을 사용하

0열

1답변

kaazing javascript 라이브러리를 통해 rabbitMQ DIRECT 교환을 사용하는 중에 오류가 발생했습니다.

kaazing javascript AMPQ 라이브러리를 통해 게시 메시지를 보낼 수 없습니다. 아래의 코드는 FANOUT 교환기에서 완벽하게 작동하지만 직접 교환기에서는 작동하지 않습니다. 연결할 수는 있지만 직접 교환기에 메시지를 게시 할 수 없습니다. function amqpTest(){ load(); var $ = function(s) { retu

1열

1답변

WAN을 통해 PHP AMQ 라이브러리 암호화 된 자격증 번호

저는 웹 인터페이스 (백엔드는 PHP)를 통해 제출 된 작업이있는 프로젝트에서 작업 중이며 WAN을 통해 서버의 대기열 (rabbitmq 백엔드)에 나타납니다. . 어떤 종류의 인증이나 암호화없이 PHP 제작자가 정상적으로 작동합니다. 저는 현재 일종의 인증을 구현하고 있습니다. (우리 서버에 일자리를 제출하는 사람이 모두 싫증나 지 않기를 바랍니다.) P

0열

2답변

RabbitMQ - PHP/Python 소비자 문제

pika 라이브러리를 사용하여 rabbitMQ 대기열에 메시지를 푸시하는 python 애플리케이션이 있습니다. message='hola' credentials = pika.PlainCredentials('guest', 'guest') connection = pika.BlockingConnection(pika.ConnectionParameters(cred

3열

1답변

흑연과 AMQP 사용하기 9.9

Graphite에 내장 된 AMQP를 사용하여 RabbitMQ를 Graphite에 연결하려고합니다. 내가 carbon.conf에서 설정의 주석을 때 내가 얻을 : 흑연 탄소 AMQP의 실제 구현이 없기 때문에 [email protected]:/opt/graphite/bin$ sudo python carbon-cache.py start Starting ca

5열

1답변

하나의 대기열 인스턴스를 여러 개의 Redis 인스턴스와 동기화하십시오.

시나리오 : 우리는 지리적으로 분산되어 있으며 그 위치에 대한 메시지를 수집하는 대기열이 있어야합니다. 그런 다음 모든 노드의 모든 대기열에서 수집 된 데이터를 중앙 위치의 해당 대기열로 보내려고합니다. 중앙 노드에서는 대기열에서 수집 된 데이터를 다른 노드에서 가져 와서 처리하고 영구 저장합니다. 제약 : 데이터는 우리에게 매우 중요합니다. 따라서 어떤

1열

1답변

Log4j + Amqp Log 예제 코드가 실패했습니다.

분산 로깅 시스템을 만들려고합니다. 각 Tomcat 인스턴스는 로그를 교환/대기열에 넣고 하나의 plcae에 저장하고 저장합니다. rabbitmq를 사용하여 Log4j + Amqp에 대해 읽었습니다. 다음 샘플 코드도 다운로드했습니다. https://nodeload.github.com/SpringSource/spring-amqp-samples/zipball

-2열

2답변

0-9-1이 AMQP 0-9-1 프로토콜의 약어

AMQP 0-9-1 프로토콜에서 0-9-1의 정확한 논리를 찾을 수 없습니다. 제발 누군가 설명해주십시오.