rabbitmq

0열

1답변

나는 spring과 rabbitmq의 통합 상황이 있습니다. 메시지는 대기열로 보내지지만 준비 상태로 끝나고 승인되지 않은 메시지로 보내지지만 소비자는 메시지를 가져 오지 않습니다. 들으 XML 구성은 다음과 같이이다 : 서버에서 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:x

0열

1답변

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

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

0열

1답변

C# 용 RabbitMQ에서 Ack를 사용하는 방법?

RabbitMQ를 사용하여 대기열에있는 일부 메시지를 가져옵니다. 하나씩. 이 내 코드의 단편이다 var data = channel.BasicGet(queue, true); if (data != null) message = System.Text.Encoding.UTF8.GetString(data.Body); else

0열

1답변

pika (python 클라이언트)를 사용하여 RabbitMQ에서 MQTT 메시지 게시/구독

기존 RabittMQ 서버 설정이 있고 MQTT 플러그인이 mqtt 메시지를 게시/구독 할 수 있도록 설정했습니다. 기존 대기열 메시지를 처리 할 pika 클라이언트가 있습니다. 지금 당장은 동일한 pika on_message() 핸들러를 사용하여 mqtt 메시지를 처리하려고합니다. eclipse paho 클라이언트를 통해 mqtt 메시지를 게시하고 구

0열

2답변

래빗 MQ 고객 이벤트 중지 큐가 비어있는 경우

RabbitMQ에 EventingBasicConsumer의 수신 이벤트 처리기를 추가했습니다. 대기열이 소비되었는지 (처리되고 비어 있음) 확인해야하며 소비자 및 연결을 닫아야합니다. 대기열이 처리되는지 여부를 알 수있는 조건을 찾을 수 없습니다. public void ProcessQueue(string queueName, Func<string, bool>

0열

1답변

rabbitmqctl 내가 내 고정 표시기 - compose.yml에서이 설정을 고정 표시기

에 오류를 반환합니다. 그러나 서버가 달려 있으며, 나는 다음과 같은 오류 가지고 rabbitmqctl 사용하는 컨테이너 입력 할 때 : 나는 rabbitmqctl list_queues Error: unable to connect to node [email protected]: nodedown DIAGNOSTICS =========== attem

0열

2답변

Spring-Boot/AMQP - 처리 할 메시지 수 제한

스프링 부트 AMQP 라이브러리를 사용하는 스프링 부팅 응용 프로그램이 있습니다. 의 pom.xml : <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 가 어떻게 그것

0열

1답변

RabbitMQ : 새 메일 알림 모델

웹 메일 서버를 쓰고 있습니다. 클라이언트에 대한 새로운 메일 알림을 위해 웹 소켓을 사용합니다. 새 이메일이 서버에 도착하면 모든 특정 웹 클라이언트에게 특정 용도로 알리고 싶습니다. 나는. 사용자가 여러 브라우저 창을 열어 놓을 수 있습니다. rabbitmq로 이것을 모델링하는 방법에 대해 조언 해 줄 수 있습니까? 사용자 당 하나의 팬 아웃 교환을 만

0열

1답변

토끼 MQ 메시지를 보낼 호출을 차단하고 메시지 제한 초과 또는 메시지 크기 제한에 대한 올바른 회신 코드를 제공하는지 확인

안녕하세요, mq 토끼 간단한 솔루션을 찾고 있습니다. 아래는 토끼에 대한 설정입니다. 토끼 서버에게 내구성 옵션 형 주제의 만들 교환 (myexchange)를 시작 . 내구성 옵션 및 x-max-length-bytes를 4로 설정하고 x-max-length를 2로 설정하여 대기열 (myqueue)을 생성하십시오. myexchange를 myqueue에 my

0열

1답변

rabbitmq ldap은 짧은 이름으로 로그인을 사용하지 못하게합니다.

rabbitmq ldap이 나를 위해 일하려고합니다. user_dn_lookup_attribute를 sAMAccountName으로 설정하고 dn_lookup_base를 DC = COMPANY, DC = com으로 설정하면 user_dn_pattern, ${username}@COMPANY.COM이 작동하지 않습니다. 예를 들어 내 로그인이 joesmo 인 경