amqp

2열

1답변

Java에서 간단한 AMQP 응용 프로그램을 만들려고합니다. 응용 프로그램은 두 클라이언트간에 숫자를 바운스해야합니다. 번호가 수신 될 때마다 클라이언트는 1을 추가하여 다른 클라이언트로 다시 보내야합니다. 그러나 예제를 전혀 사용할 수 없습니다. 나는 첫 번째 번호를 보낼 수는 있지만 결코받지 못한다. 브로커의 웹 인터페이스에서 연결 및 메시지가 전혀 표

0열

2답변

amqp에서 라우트되지 않은 메시지를 가져올 수 있습니까?

RabbitMQ 웹 UI 사용 현재 대기열 바인딩이없는 주제 교환에 게시 할 때 rabbitmq는 메시지가 게시되었지만 라우팅되지 않았 음을 나타냅니다. amqp.node를 사용하여 대기열을 Exchange에 바인드하고 "#"(모두)를 사용하여 소비하기 시작하면 아무 것도 얻지 못합니다. 이전에 게시되었지만 라우팅되지 않은 메시지가 표시 될 것으로 예상됩니

1열

1답변

rabbitmq 연결 모범 사례 게시자의 영구 연결 유지

일반적으로 SQL 연결에 대한 모범 사례는 연결을 열고 쿼리를 실행 한 다음 연결을 처분하는 것입니다. 그러나 RabbitMQ와 같은 AMQP 기반 큐 서버에 권장되는 방법은 무엇입니까? 애플리케이션이 RabbitMQ 서버에 대한 지속적인 연결을 유지하거나 게시자 측에서 전송되는 각 메시지에 대한 연결을 열고 닫아야하는지 여부 public static vo

2열

1답변

amqplib - 큐가 있는지 안전하게 확인하는 방법

나는 nodejs에 amqplib 라이브러리를 사용하여 RabbitMQ를 사용하고 있습니다. mychannel.checkQueue('xxx', function (err, ok) { console.log(err); console.log(ok) }); 를하지만 오류가 발생합니다뿐만 아니라, 채널을 닫습니다 : 나는 기능 checkQueu

0열

1답변

Apache 폭풍과 RabbitMQ Spout on Clojure

이전에 Kafka를 데이터 소스로 사용하고 있었지만 매우 강력했지만 다소 가파른 학습 곡선을 사용하여 부분적으로 작동하도록 관리했지만 여기 저기에 약간의 발목이 있었지만하지 않았습니다. 생산에서 그것을 유지하는 것이 편안함을 느낀다. Rabbitmq로 전환하기로 결정 했으므로 좀 더 익숙해졌지만 약간의 문제가있었습니다. Rabbitmq에서 Apache St

0열

1답변

아파치 Qpid HTTP REST 엔드 포인트가 응답/작동하지 Qpid 자바 브로커에 적용

: 0.32 이후 6.0.4에 아파치 Qpid HTTP REST 엔드 포인트 요청에도 불구하고 두 가지 방법으로 다음과 같은 사용하여 전송 될 때 응답하지 않는 올바른 인증 세부 사항 (사용자 이름 "admin"및 암호 "admin")이 제공됩니다. HTTP 클라이언트 : 위해 RESTClient, RESTEasy가, HttpRequester (파이어 폭스

2열

4답변

Azure IoT 허브 AMQP 통신 멀티플렉싱

Azure IoT 허브 작업을위한 Microsoft documentation 중 일부에서는 다중 TLS 연결 (AMQP 프로토콜 사용)에서 여러 장치의 통신을 멀티플렉싱 할 수 있음을 언급합니다. 장치는 IoT 허브와 통신하기에 충분히 강력한 로컬 허브 장치와 통신합니다. 이 멀티플렉싱을 구현하는 방법에 대한 예가 있습니까? DeviceClient libr

1열

2답변

낙타 AMQP에서 RESTful 끝점으로의 라우팅

나는 낙타를 처음 접해 왔으며 지금까지 재미있게 지내왔다. 그러나 이제는 AMQP에서 메시지를 읽고 메시지의 매개 변수를 사용하여 REST 끝점을 호출하는 동안 문제가 발생했습니다. 아이디어는 AMQP 메시지에 우편 번호와 집 번호 값을 얻기 위해 읽고있는 POJO가 있다는 것입니다. 이러한 값은 URL 내의 동적 필드를 채우는 데 사용됩니다. 나는 RES

1열

1답변

봄 amqp : 특정 대기열에 대한 모든 바인딩 제거

spring-amqp를 사용하여 특정 대기열에 대한 모든 바인딩을 제거 할 수 있습니까? 해결 방법이있다 , 먼저 큐를 삭제 한 다음 amqpAdmin.deleteQueue("testQueue"); amqpAdmin.declareQueue(new Queue("testQueue")); 그것을 재 선언하지만이 꽤 추한 솔루션이며 나는 그것이

0열

1답변

연결을 종료하기 전에 마지막 AMQP 메시지가 성공적으로 게시되는지 확인하는 방법은 무엇입니까?

여러 프로세스가 시스템으로 함께 작동합니다. 하나의 프로세스가 주 프로세스로 작동합니다. 시스템이 종료 될 때 모든 프로세스는 (RabbitMQ를 통해) 주 프로세스로 알림을 보내고 종료해야합니다. 이 프로그램은 C++로 작성되었으며 AMQPCPP library을 사용하고 있습니다. 문제는 알림이 게시되지 않는 경우가 있습니다. AMQPCPP 라이브러리가