amqp

0열

1답변

TLSv1.2를 사용하여 서버와 RabbitMQ 연결을 만들려고하는데 java.net.SocketException이 있습니다. 연결 재설정 또는 javax.net.ssl.SSLHandshakeException : 치명적인 경고 수신 : handshake_failure (이 예외가 변경되는 것처럼 보입니다. 무작위로). 내가 TLSv1.0을 가졌을 때 작동했

1열

1답변

RabbitMQ의 AMQP 클라이언트에서 MQTT 메시지를 구독 하시겠습니까?

MQTT/WebMQTT 플러그인을 사용하는 RabbitMQ 노드를 실행합니다. 모든 MQTT 플러그인 설정이 기본 구성을 사용합니다. 다양한 MQTT 클라이언트가 MQTT 채널로 메시지를 보내고 있습니다. MQTT 채널 이름은 내가 MQTT에 devices/#/logs 일치하는 모든 MQTT 메시지에 가입하고자하는 devices/{device_id_here

0열

1답변

RabbitMQ/AMQP 디자인 : 한 소비자가 처리 할 메시지를 어떻게 만들 수 있습니까? 그러나 모든 소비자를 관찰 할 수 있습니까?

3 개의 인스턴스/복제본 (동일한 종류의 응용 프로그램 3 개가 동시에 실행 됨)이있는 응용 프로그램이 있습니다. 그들은 모두 같은 대기열을 소비하므로 RabbitMQ는 메시지를 라운드 로빈 방식으로 전달합니다. 세 개의 인스턴스 모두는 r/w 할 단일 데이터베이스를 공유합니다. 대기열이 new-user 메시지를 수신하면이를 한 인스턴스로 전달하고 그 인스

1열

1답변

RabbitMQ + Spring 통합. 큐 크기 1 만 삭제하면 내가 지금 가망 경우 RabbitMQ와 Spring 통합이 아이디어를 구현하고자하는

재정의 : 한 큐, 1 메시지 capatity와. 소비자가이 메시지를 요청할 것입니다. 대기열에 있으면 메시지가 전달되고 그렇지 않으면 null 또는 오류가 발생합니다. 이 메시지 (대기열에있는 경우)는 다운로드 된 것으로 삭제되지 않으며 생산자가 다른 새 메시지를 대기열에 넣었을 때만 삭제됩니다. 감사합니다. 이 같은

0열

1답변

amqplib 소비 기능이있는 nodej가 닫히는 이유는 무엇입니까?

nodejs amqplib 모듈을 사용하여 rabbitmq를 연결합니다. 소비 함수가 클로저 함수가된다는 것을 알았지 만 이유를 이해할 수 없습니다. 나는 폐쇄를 사용하지 않았다. 내 코드는 다음과 같습니다. returnOK에서 corr이 여전히 처음 값을 얻은 것을 발견했습니다. 이 기능을 두 번째 발사 할 때. corr은 처음에는 여전히 값입니다. 이상

0열

1답변

RabbitMQ와의 연결 해제 후 Apache 프로세스가 종료되지 않습니다.

내 프로젝트에 Server Side Events 역학을 사용하려고했습니다. (이것은 스테로이드에 대한 긴 폴링과 같습니다) "Sending events from the server"의 예제는 아름답게 작동합니다. 몇 초 후에 연결 해제에서 아파치 프로세스가 종료됩니다. 이 방법은 잘 작동합니다. BUT! RabbitMQ을 사용하려고하면 서버가 브라우저와 연

0열

1답변

여러 AMQP 중개인에 연결

HA amqp 클라이언트를 설정하려고합니다. 현재 3 amqps 중개인이 있습니다. 현재 내 클라이언트 설정은 다음과 같습니다 : 이제 <property name="remoteURI" value="amqps://node1:9551?jms.username=XXXXXXXX&jms.password=XXXXXXXXX&transport.trustSto

-2열

1답변

MQTT는 AMQP를 사용합니까?

MQTT 중개인을 만지작 거리며 채널을 만들고 구독했습니다. 오늘 나는 RabbitMq 인터페이스에 로그인하고 mqtt-subscription-1qos1 및 mqtt-subscription-2qos1이라는 두 개의 대기열을 찾습니다. 저는 두 사람이 서로 어떻게 관련되어 있는지 모르기 때문에 혼란 스러웠습니다. MQTT가 AMQP 위에 빌드되어 큐를 작성하

0열

2답변

RabbitTemplate.send()는 RabbitMQ에 대한 메시지 전달을 보장합니까?

Spring AMQP를 사용하여 rabbitTemplate.send(message) 메소드를 호출하면 (org.springframework.amqp.rabbit.core.RabbitTemplate 클래스에서) 메시지가 전달되고 RabbitMQ 클러스터에 복제되었는지 확인할 수 있습니까?

0열

1답변

org.springframework.amqp.AmqpIllegalStateException : '대기열'이 지정되지 않았습니다. RabbitTemplate 구성 확인

rabbitmq에서 메시지를 읽고 oracle 데이터베이스에 씁니다. 나는 스프링 부트 배치를 사용하여 메시지를 읽었지만 "큐가 지정되지 않았습니다."라는 오류로 끝납니다 .RabbitTemplate의 구성을 확인하십시오. " RabbitConfig.java @Configuration public class RabbitMQConfig { // @Val