amqp

0열

1답변

몇 가지 작업을 수행 할 수있는 컴퓨터가 여러 대 있습니다. 작업을 시작하기 위해 예를 들어 컴퓨터 ID "12345"라는 대기열에 메시지를 보내려고합니다. 다른 사람이 이러한 메시지를 사용하지 못하게하려면 큐가 독점적이어야합니다. 그러나 내 컨트롤러에서 큐를 소비하는 시스템에서 독점적으로 선언 된 경우 큐를 주장 할 수 없습니다. 그러나, 나는 주장하지

2열

1답변

노드의 amqplib을 ssl 연결과 연결하는 방법은 무엇입니까?

나는 SSL을 사용하도록 강요 받고 사용자와 암호로 보호 된 내 RabbitMQ 서버에 연결하려고합니다. 이전에는 C#, PHP 및 Python 응용 프로그램에서이 서버에 연결하는 데 성공했습니다. 이 내 Node.js를 코드 : const amqp = require('amqplib'); const fs = require('fs'); const con

0열

1답변

RabbitMQ 대기열 선언이 끝나지 않습니다

난 그냥 RabbitMQ에 대한 간단한 테스트를하려고하는데, Erlang이 설치되어 있고 RabbitMQ가 실행 중입니다. 내 수신기 :이 "channel.queueDeclare"라인에 큐를 선언 걸리면 때문에 private final static String QUEUE_NAME = "hello"; public static void main(String

1열

1답변

처리 방법 AMQP/노드를 사용하여 초당 100 개의 메시지

우리는 현재 RabbitMQ (RabbitMQ 3.6.12, Erlang 19.2)의 초당 60-150 개의 메시지를 소비해야하는 마이크로 서비스 (노드 v8.3.0)를 프로토 타이핑하고 있습니다. .1). 때로는 매력처럼 작동하고 대기열에 남아있는 메시지가 없습니다. 그러나 메시지가 갇히지 않는 대부분의 경우 초당 5-20 개의 메시지 만 처리되어 대기열

1열

2답변

소비자의 승인을 생산자에게 보내고 activemq 및 rabbitmq에서 처리합니다.

ActiveMQ에는 실제로 메시지가 수신되었음을 알리는 AUTO Acknowledge라는 기능이 있습니다 (생산자를 인정하지 않음). ActiveMQ 또는 RabbitMQ에서 소비자의 승인을 보낼 수 있는지 알고 싶습니다. 생산자에서 확인 응답 메시지를 처리하고 응답을받지 못하면 소비자에게 다시 메시지를 보냅니다.

0열

1답변

30-40 분 후 대기열에서 소비자가 사라짐

내 고객은 RabbitMQ Admin의 소비자 목록에서 30-40 분 동안 잘 작동 한 후에 앱이 사라집니다. 사용되는 AMQP 라이브러리 : node-amqp. 다음 이벤트 핸들러가 너무 구성되어 const con = amqp.createConnection(options,{defaultExchangeName: 'amq.topic', reconnect: t

0열

1답변

AMQP assertQueue 주방장 AMQP의 assertQueue의 API 문서에서

, 그것은 상태 의미 연결 : 가 존재로 큐를 주장한다. 이 연산은 동일한 인수가 주어지면 멱등수입니다. 그러나 큐가 이미 존재하지만 다른 속성을 가진 경우 (큐 필드에 제공된 값은 보킹 목적으로 계산 될 수도 계산되지 않을 수도 있습니다.), 브로커의 문서를 참조하십시오. http://www.squaremobius.net/amqp.node/channel_

0열

2답변

아파치 QPID JMS 클라이언트 설정 프리 페치 내가 이와 같은 URI로 구성된 <code>JmsConnectionFactory</code>이

작동하지 않습니다 failover:(amqps://11.22.33.44?amqp.idleTimeout=120000&transport.tcpKeepAlive=true&jms.prefetchPolicy.all=10)?failover.maxReconnectAttempts=20 주 공식 documentation 에 따라 jms.prefetchPolicy.all=1

0열

1답변

RabbitMQ는 유형별로 청취자를 구분합니다.

토끼 MQ에 메시지를 나타내는 POJO가 있습니다. 메시지의 유형에 대한 책임이 정수 (그래서 그것의 여부를 update, remove, add과)이 있습니다 : public class Message { private String field1; private String field2; private Integer type;

1열

1답변

런타임시 @RabbitListener를 생성하는 가장 쉬운 방법

런타임시 이것을 구성하는 가장 쉬운 방법은 무엇입니까? @RabbitListener(bindings = @QueueBinding( value = @Queue(value = "providedAtRuntime", durable = "true"), exchange = @Exchange(value = "providedAtRuntime", ignor