message-queue

0열

2답변

Jms 브로커 연결 - 대기열을 청취하기 전에 연결을 테스트하십시오. - java

대기열을 수신 대기하는 메시지 수신기가 있습니다. 메시지 브로커가 중지되거나 종료되면 응용 프로그램이 갑자기 종료됩니다. 대기열을 수신하기 전에 JMS 브로커 연결을 확인하는 방법이 있습니까? 리스너 코드는 JMS 브로커가 작동중인 경우에만 사용 가능해야합니다. 우리는 당신이있는 경우에만 성공의 ActiveMQ와 때마다 당신에게 설치 연결로 당신이 당신의

0열

1답변

vertx에서 eventbus 메시징을 사용하는 방법은 무엇입니까?

나는 sample의 지침을 따라 달렸다 : vertx run eventbus_pointtopoint/receiver.rb -cluster vertx run eventbus_pointtopoint/sender.rb -cluster 그럼 난 단지 가지고 : ➜ ruby vertx run eventbus_pointtopoint/receiver.rb -clu

0열

1답변

App Engine : queue.yaml에서 req/sec 대신 req/min 속도를 설정할 수 있습니까?

Google은 읽기 및 쓰기 횟수에 15000/분 제한을두고 있습니다. 이 제한에 따라 유지하기 위해, 나는 15000/분 == 250/초를 계산, 나의 큐의 설정은 다음과 같습니다 name: mapreduce-queue rate: 200/s max_concurrent_requests: 200 내가 직접 queue.yaml에서 15000/min의 속

1열

1답변

아파치 카프카 메시지 발송 및 균형로드

저는 아파치 카프카에서 시작하여 실제로 어떻게 사용할지 내 시스템을 어떻게 설계 할 수 있는지 알아 내려고합니다. 저는 데이터를 처리하는 시스템을 구축하고 있습니다. 실제로 데이터의 청크는 처리해야 할 작업 (객체)입니다. 객체는 처리 방법을 알고 있으므로 문제가되지 않습니다. 내 시스템은 실제로 게시자 (작업 시작 코드), 전송 - 실제로 카프카 및 소비

3열

1답변

단일 생산자 인 다중 생산자, 큐에 단일 큐가있는

저는 RabbitMQ에 대해 처음이에요. 하나의 대기열에 다중 생산자와 다중 소비자를 가진 프로그램을 작성해야합니다. 이미지에 표시된 내용을 수행 할 수 있습니까? 나는 많은 예제를 발견했지만 그들은 모두 단일 제작자입니다. 모든 제작자가 모든 소비자에게 메시지를 보냅니다. 한마디로

0열

1답변

크기가 다른 Linux 메시지 대기열 (POSIX 또는 SysV)에서 신호를 처리하는 방법은 무엇입니까?

신호가 다른 크기의 Linux Message Queue (POSIX 또는 SysV) 신호를 처리하는 가장 좋은 방법은 무엇입니까? 크기가 다른 둘 이상의 신호를 수신 할 수있는 프로세스가 있다고 가정합니다. 예를 들면 : struct sig1 { long mType; char data[10]; }; struct sig2 {

0열

2답변

메시지 큐를 사용하여 Control-M에서 작업을 어떻게 주문할 수 있습니까?

외부 응용 프로그램의 메시지를 통해 Control-M 작업을 주문하는 방법을 찾으려고합니다. 우리는 Control-M v8을 사용하고 있습니다. 큐에 메시지를 보낼 수 있지만 Control-m에서 일종의 작업을 수행하는 메시지를받지 못했습니다.

0열

1답변

동시 처리는 연대순으로 처리됩니다.

성능면에서 C++로 작성된 메시지 디코더를 최적화하고 싶습니다. 디코더는 완전히 순차적으로 설계되었습니다. 실제 병렬화의 개념은 간단합니다. 새 소켓에 데이터가 도착하자마자 수신 된 메시지를 디코딩 할 다른 스레드를 실행하도록 스레드 풀에 알립니다. 각 스레드의 끝에서 메소드가 호출됩니다 (즉, Qt 신호가 방출 됨). 그리고 처리 중에 작성된 오브젝트가

0열

1답변

Apache ActiveMQ에서 JMX를 활성화하는 방법

ActiveMQ에서 JMX를 활성화하려고합니다. 나는이 페이지의 지침에 따라하고 다음과 같이 내 브로커 태그 인 activemq.xml에서 http://activemq.apache.org/jmx.html : broker xmlns="http://activemq.apache.org/schema/core" brokerName="BROKER1" dataDirec

0열

1답변

Android MessageQueue

메인 (UI) 스레드는 MessageQueue를 갖기 위해 스레드에 암시 적 루퍼가 첨부되어 있습니다. 그리고 우리는 또한 우리가 Looper.prepare()의 도움으로 작업자 스레드에 MessageQueue가 첨부 수 있다는 사실을 알고 내 질문은 그게은 동일 모두 대기열입니다?