consumer

0열

1답변

RabbitMQ는 교환기를 통해 여러 대기열에 게시합니다. 첫 번째 대기열에만 게시합니다.

게시하고자하는 여러 대기열 교환기가 있습니다 (일부 대기열에만 게시하고 모든 대기열에 게시하지 않으려는 경우 팬 아웃이 작동하지 않습니다.)) 코드는 다음과 같이 진행됩니다 public int pushDataOverRabbitMQ(String[] deviceIDs, String msg) throws IOException { int retrunVa

1열

2답변

C : 생산자/소비자

학교에서 맡은 일 중 하나는이 코드를 수정하는 것입니다. 생산자와 소비자 스레드는 지역 변수를 교대로 증가시키고 인쇄해야하지만 어떻게 수정해야하는지 잘 모릅니다. 생산자와 소비자 스레드가 무한히이를 수행 할 수 있어야합니다. 그러나 실행 파일을 시작하면 임의로 중지됩니다. 누군가이 동작을 설명 할 수 있다면 좋을 것입니다. #include <sys/type

-1열

1답변

파일을 정확히 한 번 처리하는 방법

Java 응용 프로그램이 디렉토리에서 데이터를 읽고 공통 공유 리소스 대기열에 넣으면 소비자가 이벤트를 사용하여 이벤트의 유효성을 검사하고 데이터베이스에 저장합니다. 디렉토리의 파일을 처리하려고합니다. 응용 프로그램이 다시 시작된 경우에도 한 번만 파일을 다시 처리해야합니다. 중지 된 곳의 파일에서 시작해야합니다. 아무도 도와 줄 수 없습니다.

3열

2답변

mule esb 웹 서비스 사용자 SOAP - 오류 : 접두어를 지정하지 않았습니다.

Mule ESB 3.5.0의 예제 프로젝트 "tshirt-service-consumer"의 흐름 "listInventory"를 재현하려고합니다. 하지만 프로젝트를 실행할 때 콘솔에 오류가 있습니다. WARN 2014-07-20 22:16:21,541 [main] org.mule.module.ws.consumer.RequestBodyGenerator: Una

27열

1답변

RabbitMQ에서 재시도 횟수를 어떻게 설정합니까?

나는 RabbitMQ를 사용하고 있으며 전자 메일 메시지를 보관하는 대기열이 있습니다. 내 고객 서비스는 메시지를 대기열에서 제외하고 메시지를 보내려고합니다. 어떤 이유로 든 내 고객이 메시지를 보낼 수 없으면 메시지를 다시 보내서 다시 보내고 싶습니다. 나는 basicNack을 할 수 있고, 큐 플래그를 true로 설정할 수 있다는 것을 알았지 만, 메시

2열

1답변

bramqp & node.js : 소비자 취소시 오류 (basic.cancel)

첫 번째로, 나는 rabbitmq와 bramqp를 처음 사용합니다. 이것은 어리석은 질문일지도 모르지만 나는 큐에서 소비자를 취소하는이 문제 때문에 내 머리카락을 꺼내왔다. 나는 전체 인터넷을 검색했고 basic.cancel 코드를 수행하는 방법에 대한 bramqp 예제를 발견하지 못했습니다. var bramqp = require('bramqp');

0열

1답변

소비자 할당 RabbitMQ

rabbit-mq 소비자 배포를 디자인 할 때 도움이 필요합니다. 예를 들어, 100 개의 대기열에서 메시지를 소비하는 100 개의 대기열과 10 개의 스레드가 있습니다. 각 스레드는 각각 10 개의 큐에서 메시지를 소비합니다. 질문 1 : 스레드를 동적으로 대기열에 할당하는 방법? 쓰레드가 다른 머신에서 실행되고 있다면? 큐에서 하나 이상의 스레드가 큐에

1열

1답변

AMQP 소비자가 CPU를 100 %로로드합니다.

이 설치된 Symfony2 응용 프로그램이 있습니다. 번들 문서화에 설명 된대로 소비자 및 제작자를 설정했으며 모든 것이 올바르게 작동합니다. 하지만 내 고객은 으로 시작했습니다. /app/console rabbitmq : 소비자는 사용 가능한 모든 CPU 시간을 사용합니다. 기본적으로 소비자는 메시지를 기다리고 출력합니다. 데모 소비자가 php-amqpl

2열

1답변

하나의 JMS 소비자가 활성 mq 주제를 듣지 않고 초 동안

봄 석영 프로세스는 프로젝트에서 매 15 분, 즉 하루에 96 번 실행됩니다. 이것은 특정 레코드를 데이터베이스에서 가져 와서 REST 서비스 (JBoss 7에서 실행 중)에 POST합니다. 이러한 기록은 일반적으로 50에서 100 사이입니다. REST 서비스에서이 메시지를 주제에 게시하는 jms 이벤트 발행자가 있습니다. 이 주제에는 두 명의 소비자가 있

0열

1답변

JMS 큐 소비자 : 동기 receive() 또는 단일 스레드 onMessage()

Q에서 소비해야하며 각 메시지에 순서 키를 찍어서 순서를 표시해야합니다. 즉, 소비는 순차적 일 필요가있다. 성능/처리량 관점에서, onMessage() 메소드에서 블로킹 receive() 메소드 또는 비동기 리스너를 단일 스레드 구성으로 사용하는 것이 더 좋을까요? 감사합니다.