message-queue

0열

1답변

MQ 큐에서 "보통"MQGET을 수행 할 때 만료 된 메시지 (만료 시간이 경과 한 메시지)는 검색되지 않습니다. 대신, 그들은 버려지고 대기열의 다음 메시지가 시도됩니다. 제 질문은 와 관련이 있습니다. MQGET 작업. 특정 상관 ID가있는 메시지를 구체적으로 찾고 있기 때문에 만료 된 메시지가 삭제되는 정상적인 메커니즘을 우회합니까? 즉, 특정 메시지

2열

1답변

Azure 서비스 버스 : 재시도 정책이 내장 된 메시지 펌프를 통해 수신 된 일시적인 오류 (예외). 왜?

OnMessageOptions.ExceptionReceived Event, RetryPolicy (2013 년 5 월, RetryPolicy.Default), The Transient Fault Handling Application Block (2011) 및 더 많은 정보 (하단 참조)가 소개 된 Event-Driven Message Programming

0열

1답변

들어오는 웹 API 2 호출 대기

내 웹 API 서비스에 처리하는 데 많은 시간이 걸리는 많은 양의 데이터를 수신합니다 (구문 분석, 데이터 처리, DB에 넣기 등). 내가 가지고있는 문제는 데이터의 다음 덩어리가 올 때 처리가 항상 완료되지 않는다는 것입니다. 나는 동시에 데이터를 처리하고 싶지는 않지만 첫 번째 호출이 다음 호출을 처리하기 전에 완료 될 때까지 기다린다. RabbitMQ

2열

1답변

RabbitMQ : 데드 레터 메시지가 다시 죽을 수 있습니까?

우리는 2 개의 대기열과 x-dead-letter-exchange/x-message-ttl을 사용하여 지연된 메시지 처리를 구현했습니다. 여기서 queue1의 메시지 시간 초과 후 queue2로 이동합니다. 이제 RabbitMQ를 설정하여 queue2의 메시지를 처리하는 중에 "dead-letter"로 거부하면 자동으로 queue3으로 이동합니다. 대기열

0열

1답변

프로세스가 다른 프로세스에서 생성 한 큐에 대한 메시지 큐 설명자를 알 수있는 방법은 무엇입니까?

mq_open()은 mqd_t 형식의 메시지 대기열 설명자를 반환하는 POSIX 메시지 대기열을 만들 수 있습니다. 다른 프로세스가 mq_notify() 또는 mq_receive()를 통해 메시지를 수신해야하는 경우 메시지 큐 설명자를 인수로 사용해야합니다. 대기열 이름을 사용하여 메시지 대기열 기술자를 얻는 방법이 있습니까? 그렇지 않은 경우 메시지 큐를

2열

2답변

사용자 정의 데드 레터 대기열 작성

activemq 5.10을 사용하고 있습니다. 모든 대기열에 사용자 정의 데드 레터 대기열을 작성하려고합니다. activemq 자체가 이름이 ActiveMQ.DLQ 인 내장 DLQ를 제공하지만 내 사용자 정의 DLQ가 실패한 모든 메시지를 보유하기를 원합니다. 는 또한 우리가 각 대기열에 대한 개별 DLQ를 만들 수 있다는 것을 알고,하지만 난 어떤 포인터

2열

1답변

ActiveMQ에서 메시지 저장 및 처리

ActiveMQ를 사용하여 내 메시지를 소비자에게 게시하여 소비자가 메시지를 수신 할 수 있도록하고 트리거합니다. 이제 내 질문에 ActiveMQ가 메시지 그룹을 저장하고 처리 할 수 있습니까? 예 : 한 번에 여러 개의 메시지 그룹이 게시되면 처음 두 개와 프로세스를 가져와야합니다. 나머지는 기다려야합니다. 이 두 메시지가 처리 된 후 다른 메시지를

3열

2답변

응용 프로그램에서 MSMQ 메시지를 사용하지만 실패하면 어떻게됩니까?

내가 Bob에게 샌드위치를 가져 오라고 요청하면 Bob이 "Ok"라고 말하지만 상점에서 돌아 오는 길에 버스를 타면 결코 샌드위치를 얻을 수 없습니다. 내 샌드위치를 사러 가지 않을거야! - 그래서 나는 다른 사람에게 말하지 않는다. "이봐, 배고프다!" MSMQ에서이 문제를 해결할 방법이 있습니까? 다른 사람에게 전달되지 않도록 메시지를 예약

4열

3답변

AMQP basic.get 동시 사용자가 대기열에서 빠져 나오다

메시지 브로커로 RabbitMQ를 사용할 때 여러 동시 사용자가 basic.get AMQP 메소드를 사용하여 대기열에서 메시지를 가져오고 대기열에서 메시지를 삭제하기위한 명시적인 확인을 사용하는 시나리오가 있습니다. . 다음 설정을 가정 할 경우 Q에는 메시지 M1, M2, M3이 있으며 소비자 C1, C2 및 C3 (각각 자체 연결 및 채널을 가짐)이 연

0열

2답변

이전에 작업을 이미 대기열에 추가했는지 여부를 어떻게 확인할 수 있습니까?

이전에 대기열에 추가되지 않은 경우에만 App Engine Task Queue에 작업을 추가하고 싶습니다. 이미 대기열에 있는지 여부를 어떻게 확인할 수 있습니까? 태스크 큐 API에서 명확하지 않았지만, 아마도 그것을 놓쳤습니다. 태스크 (param?)의 핵심은 user_id입니다. 사례 : 매분마다 새 메시지를 계속 확인합니다. 이것은 매우 자주 일어날