amqp

0열

1답변

한 사용자에게서 다른 사용자에게 메시지를 보낼 때 RabbitMQ에서 차단 차단

최근에 rabbitmq를 사용하기 시작했습니다. 프론트 엔드에서는 SockJS + Stomp를 사용합니다. rabbitmq에서는 "topic"유형으로 교환 "메시지"를 작성합니다. 연결시 Stomp는 amq.gen-Uf_bUS-5GG3WyzOn_avMig와 같은 대기열을 만들고 "메시지"에 가입합니다. 액세스 권한을 이해할 수 없습니다. 간단한 동작을 고려

1열

1답변

qpid-proton이 필요합니다 python이 Azure에 액세스 할 수 있도록 amqp 샘플 프로그램이 필요합니다.

Azure 클라우드 서비스 버스를 사용하여 AMQP 프로토콜을 사용하여 메시지를 보내고받습니다. 데비안 -Linux에 proton-c 라이브러리를 설치했습니다. 나는 대기열에서 메시지를 보내고 받기 위해 아래 프로그램을 시도했다. 내 요구 사항은 대기열 대신 사용 주제가 있습니다. 누구든지 Azure 클라우드에서 주제를 사용하는 샘플 프로그램을 제공하십시오

4열

2답변

RabbitMQ 클라이언트 인증 예외가있는 QPID 브로커

Java QPID 브로커를 사용하여 테스트 중입니다. 양성자 클라이언트를 사용하지만 익명 인증을 사용하여 메시지를 보내고받을 수있었습니다. 인증을 켜고 테스트하는 데 관심이 있으며 양성자 클라이언트가 (아직) 지원하지 않는다는 것을 이해합니다. 그래서 나는 rabbitMQ 클라이언트 항아리를 다운로드했다. 암호 파일 인증 (QPID와 함께 제공)을 사용하고

0열

1답변

연결이 거부되었습니다. RabbitMQ

저는 RabbitMQ를 처음 사용하고 간단한 예를 시도하고 있습니다. 아래는 내 자바 소스 : import com.rabbitmq.client.ConnectionFactory; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Channel; public class Send {

4열

1답변

RabbitMQ : 프리 페치 메시지 처리

RabbitMQ와 함께 사용하기 위해 Spring AMQP를 사용하고 있습니다. 여기 내 구성입니다 : <rabbit:connection-factory id="connectionFactory" host="${queue.host}" port="${queue.port}" /> <rabbit:template id="amqpTemplate" connec

2열

1답변

amqpcpp를 컴파일 할 수 없습니다. 오류가 발생합니다.

centos 가상 시스템에서 amqpcpp를 컴파일하는 데 문제가 있습니다. 그러나 iMac에서 제대로 작동합니다. 것은 내가이 오류를 얻을 수 있도록 실행하고 때 g++ -Wall -I/usr/local/include -L/usr/local/lib -Iinclude/ -c -o src/AMQPExchange.o src/AMQPExchange.cpp sr

0열

1답변

rabbitmq 수백 개의 고유 키가있는 주제 교환에 대한 백 큐 바인딩

다중 대기열에 배치 될 200 개의 이벤트가 있다고 가정하고 각 대기열을 200 개의 고유 키가있는 주제 교환에 바인딩하려고합니다 . 하나의 대기열과 하나의 교환기간에 200 개의 고유 한 바인딩을 추가하여 성능에 병목 현상이 발생 했습니까? 예인 경우 다른 방법이 있습니까? 일반적으로 사전

2열

1답변

RabbitMQ의 만료 시간

지연 메시지 처리에 RabbitMQ를 사용합니다. 구현을 위해 WorkQueue와 WaitQueue의 두 대기열을 사용합니다. 처음에는 메시지가 만료 된 시간과 함께 WaitQueue에 전달됩니다. 이 시간이 지나면 WorkQueue로 이동해야합니다. 그러나 그것은 효과가 없습니다. 2 개의 메시지를 넣는 경우 : 만료 시간 1 분 10 분. 이 경우 두

0열

1답변

로컬 연결에 amqp : // user : password @ localhost 대신 amqp : // user : password @를 사용할 수 있습니까?

단축 구문을 사용할 수 있습니까? 이렇게 짧은 amqp url을 사용하면 rabbitmq가 "직접"모드로 작동하게되어 더 효율적입니다. 그러나 내가 그런 삽에 대한 로컬 연결 설정을 변경하면 더 이상 연결 목록에 이러한 연결이 표시되지 않습니다.

3열

1답변

AMQP 연결 노드 js와 특정 시간 간격을 닫습니다.

아래의 문제로 지난 3 일 동안 사용해 보았습니다. 이 문제를 해결하는 데 도움이되도록 >Error: Unexpected close at succeed (/usr/local/lib/node_modules/amqplib/lib/connection.js:259:13) at onOpenOk (/usr/local/lib/node_modules/amqplib/l